Allen Wang created KAFKA-5724: --------------------------------- Summary: AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero Key: KAFKA-5724 URL: https://issues.apache.org/jira/browse/KAFKA-5724 Project: Kafka Issue Type: Bug Components: clients, consumer Affects Versions: 0.11.0.0 Reporter: Allen Wang
In AbstractPartitionAssignor.assign(Cluster metadata, Map<String, Subscription> subscriptions), it invokes assign(partitionsPerTopic, subscriptions). It assumes that partition number starts from 0, and it constructs TopicPartition in the range of [0, partitionsPerTopic). This assumption is not correct. The correct way to handle it is to follow the same approach in producer's DefaultPartitioner, where it uses [0, numberOfPartition) as an index to the actual partition. There are use cases where partition number may not start from zero. It can happen if users use advanced tooling to manually craft the partition number when creating topics. -- This message was sent by Atlassian JIRA (v6.4.14#64029)