Module kafka_protocol::compression

source · [−]
Expand description

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

Gzip

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

None

Noop compression implementation.

Snappy

Snappy 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.