Skip to main content

Module partitioner

Module partitioner 

Source
Expand description

Kafka partitioning strategies.

KafkaPartitioner determines which Kafka partition each record is sent to. Three strategies are provided:

Structs§

KeyHashPartitioner
Key-hash partitioner using Murmur2 (Kafka-compatible).
RoundRobinPartitioner
Round-robin partitioner distributing records evenly across partitions.
StickyPartitioner
Sticky partitioner that batches records to the same partition.

Traits§

KafkaPartitioner
Trait for determining the target Kafka partition for a record.