...
This is the default partitioning logic for messages without keys, that substitutes the corresponding logic implemented in the default partitioner. The default partitioner now can return -1 for messages without keys so that default partitioning logic can be executedpartitioning logic is going to be implemented in the KafkaProducer
itself. KafkaProducer
would explicitly check if the partitioner is an instance of DefaultPartitioner
or UniformStickyPartitioner
and would run partitioning logic instead of calling into partitioner.partition function.
Uniform Sticky Batch Size
...