如何解决Kafka 中消费者的词典顺序究竟是什么意思?
这个问题似乎很简单,但我还没有找到解释。 kafka 中默认的分区分配策略是使用 RangeAssignor。此分配器的工作方式解释如下:
“范围分配器在每个主题的基础上工作。对于每个主题,我们按数字顺序布置可用分区,并按字典顺序布置消费者。然后我们将分区数量除以“消费者总数决定了分配给每个消费者的分区数量。如果不是均匀划分,那么前几个消费者将多出一个分区。” https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html
到目前为止,它的工作原理已经很清楚了。不清楚字典顺序是在什么属性上完成的。是通过消费者的 id 完成的吗? 任何人都可以举例说明消费者的词典顺序吗?
您好,
莫迪斯
解决方法
由于不需要消费者客户端 id 并且组 id 应该仅用于偏移管理,我假设它是指主题名称,当消费者订阅多个主题时。如果你只使用一个主题,那么只有分区是按数字顺序排列的
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。