Enum Compression 

#[non_exhaustive]
#[repr(i16)]
pub enum Compression {
    None = 0,
    Gzip = 1,
    Snappy = 2,
    Lz4 = 3,
    Zstd = 4,
}

Kafka record-batch compression codec, encoded in bits 0–2 of the batch attributes field.

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 = 0

No compression.

Gzip = 1

Gzip (flate2).

Snappy = 2

Snappy (snap).

Lz4 = 3

LZ4 frame format (lz4_flex).

Zstd = 4

Zstandard (zstd crate).

Implementations

impl Compression

pub const fn from_attributes(attributes: i16) -> Result<Self>

Decode the codec from a record-batch attributes field. Only bits 0–2 are examined; higher bits are masked off.

pub fn compress(self, payload: &[u8]) -> Result<Vec<u8>>

Compress payload at the codec default level.

pub fn compress_with_level( self, payload: &[u8], level: Option<i32>, ) -> Result<Vec<u8>>

Compress payload at the given level (codec-specific).

• Gzip accepts 0..=9, default 6.
• Zstd accepts 1..=22, default 3.
• Snappy ignores the level.
• Lz4 level handling depends on the active backend feature:
  • with lz4 only — level ignored, always fast mode.
  • with lz4-hc — level 0..=2 → fast, 3..=12 → HC mode, values above 12 clamp to 12, negative/zero levels clamp to fast level 1.

pub fn decompress(self, payload: &[u8]) -> Result<Vec<u8>>

Decompress payload. Returns the decompressed payload, or an error if the required Cargo feature is not enabled.

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Compression