【问题标题】:What does lexicografic Order of Consumers in Kafka exactly mean?Kafka中消费者的词典顺序到底是什么意思?
【发布时间】: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


    【解决方案1】:

    由于消费者客户端 ID 不是必需的,并且组 ID 应该只用于偏移管理,我假设它是指主题名称,当消费者订阅多个主题时。如果你只使用一个主题,那么只有分区是按数字排序的

    【讨论】:

    • 嘿@OneCricketeer,感谢您的回复。如果我猜对了,那么 RangeAssignor 就像 Round Robin 一样,因为消费者只订阅了一个主题?
    • 听起来合乎逻辑。
    猜你喜欢
    • 2018-10-08
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-07-06
    • 2012-04-04
    • 1970-01-01
    • 1970-01-01
    • 2017-08-07
    相关资源
    最近更新 更多