卡夫卡的词典编纂《消费者秩序》究竟意味着什么



这个问题看起来很简单,但我还没有找到解释。kafka中默认的分区分配策略是使用RangeAssignor。该转让人的工作方式解释为:

"范围转让人在每个主题的基础上工作。对于每个主题,我们以数字顺序排列可用分区,以词典顺序排列消费者。然后,我们将分区的数量除以使用者的总数,以确定分配给每个使用者的分区数量。如果它不能平均划分,那么前几个消费者将有一个额外的分区"https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html

到目前为止,它是如何运作的还很清楚。词典编纂顺序的属性尚不清楚。是否由消费者的id完成?有人能举例说明消费者的词典编纂顺序吗?

问候,

maudeees

由于消费者客户端id不是必需的,并且组id只应用于偏移量管理,因此我认为当消费者订阅了多个主题时,它的意思是主题名称。如果您只使用一个主题,那么只有分区是按数字顺序排列的

最新更新