Expand description
Kafka partitioning strategies.
KafkaPartitioner determines which Kafka partition each record is
sent to. Three strategies are provided:
KeyHashPartitioner: Murmur2 hash (Kafka-compatible default)RoundRobinPartitioner: Cycle through partitionsStickyPartitioner: Batch to one partition until threshold
Structs§
- KeyHash
Partitioner - Key-hash partitioner using Murmur2 (Kafka-compatible).
- Round
Robin Partitioner - Round-robin partitioner distributing records evenly across partitions.
- Sticky
Partitioner - Sticky partitioner that batches records to the same partition.
Traits§
- Kafka
Partitioner - Trait for determining the target Kafka partition for a record.