【发布时间】:2021-08-22 11:31:19
【问题描述】:
这个问题似乎很简单,但我还没有找到解释。 kafka 中默认的分区分配策略是使用 RangeAssignor。该转让人的工作方式解释为:
“范围分配器在每个主题的基础上工作。对于每个主题,我们按数字顺序排列可用分区,并按字典顺序排列消费者。然后我们将分区数除以消费者总数来决定分配给每个消费者的分区数量。如果不均分,那么前几个消费者会多出一个分区。 https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html
到目前为止,它的工作原理很清楚。不清楚字典顺序是在什么属性上完成的。是由消费者的 id 完成的吗? 任何人都可以举一个消费者词典顺序的例子吗?
您好,
莫迪
【问题讨论】:
标签: apache-kafka partition consumer