Bharat Viswanadham created KAFKA-4087:
-----------------------------------------
Summary: DefaultParitioner Implementation Issue
Key: KAFKA-4087
URL: https://issues.apache.org/jira/browse/KAFKA-4087
Project: Kafka
Issue Type: Bug
Components: producer
Affects Versions: 0.9.0.1
Reporter: Bharat Viswanadham
Assignee: Bharat Viswanadham
In DefaultPartitioner implementation, when key is null
if (availablePartitions.size() > 0) {
int part = Utils.toPositive(nextValue) %
availablePartitions.size();
return availablePartitions.get(part).partition();
}
Where as when key is not null
return Utils.toPositive(Utils.murmur2(keyBytes)) % numPartitions;
We are returning partition by using total number of partitions.
Should n't we do the same as by considering only available partitions?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
