Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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

...