Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
2.4.0, 2.5.0, 2.4.1
-
None
-
None
Description
RoundRobinPartitioner states that it will provide equal distribution of records across partitions. However with the enhancements made in KIP-480, it may not. In some cases, when a new batch is started, the partitioner may be called a second time for the same record:
Each time the partitioner is called, it increments a counter in RoundRobinPartitioner, so this can result in unequal distribution.
Easiest fix might be to decrement the counter in RoundRobinPartitioner#onNewBatch.
Attachments
Issue Links
- duplicates
-
KAFKA-13303 RoundRobinPartitioner broken by KIP-480
- Patch Available
- links to