Module compression

Provides compression utilities for encoding records.

This module has implementations of gzip, Snappy, as well as a noop compression format that allows encoding and decoding records into a Record.

Structs

Gzipgzip

Gzip compression algorithm. See Kafka’s broker configuration for more information.

Lz4lz4

Gzip compression algorithm. See Kafka’s broker configuration for more information.

None

Noop compression implementation.

Snappysnappy

Snappy compression algorithm. See Kafka’s broker configuration for more information.

Zstdzstd

Gzip compression algorithm. See Kafka’s broker configuration for more information.

Traits

Compressor

A trait for record compression algorithms.

Decompressor

A trait for record decompression algorithms.