当前位置:  开发笔记 > 大数据 > 正文

卡夫卡消费者中groupid和consumerid之间的差异

如何解决《卡夫卡消费者中groupid和consumerid之间的差异》经验,为你挑选了1个好方法。

我是卡夫卡的新手.我注意到在Consumer配置中有两个id.一个是group.id(强制性),第二个是consumer.id(非强制性).请告诉我为什么2 Ids和差异.



1> Aravind R. Y..:

消费者群体是Kafka抽象,支持点对点和发布/订阅消息传递.消费者可以group_1通过将其设置group.id为加入消费者群体(我们说)group_1.消费者群体也是支持数据的并行消费的一种方式,即同一消费者群体的不同消费者从不同分区并行地消费数据.

除了group.id之外,每个消费者还使用Kafka经纪人识别自己consumer.id.Kafka使用它来识别特定消费者组的当前ACTIVE消费者.

阅读此文档以获取更多详细信息


如果您尚未对主题进行分区,则只有1个消费者将使用消息.如果您希望两个使用者(属于同一个使用者组)并行使用消息,那么您需要对主题进行分区.我建议你阅读文档
阅读有关“ consumer.id”的文档,描述指出“如果未设置则自动生成”。我认为这可能意味着,如果手动设置,consumer.id对于每个使用者都应该是唯一的?好奇地想知道,如果您在多个消费者之间重用消费者ID(例如,如何共享消费者组ID)会出现问题,或者它可以正常工作,但对于跟踪/调试组中的活跃消费者却很混乱?
推荐阅读
农大军乐团_697
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有