Enum Compression 

#[non_exhaustive]
pub enum Compression {
    None,
    Gzip,
    Snappy,
    Lz4,
    Zstd,
}

Kafka record batch compression policy for producer sends.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

None

Do not compress produced record batches.

Gzip

Compress produced RecordBatch v2 payloads with gzip.

Snappy

Compress produced RecordBatch v2 payloads with Kafka-compatible Snappy framing.

Lz4

Compress produced RecordBatch v2 payloads with Kafka-compatible LZ4 framing.

Zstd

Compress produced RecordBatch v2 payloads with Kafka-compatible Zstd framing.

Trait Implementations

impl Clone for Compression

fn clone(&self) -> Compression

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for Compression

impl Debug for Compression

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for Compression

impl PartialEq for Compression

fn eq(&self, other: &Compression) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Compression