我是卡夫卡的新手.我注意到在Consumer配置中有两个id.一个是group.id(强制性),第二个是consumer.id(非强制性).请告诉我为什么2 Ids和差异.
消费者群体是Kafka抽象,支持点对点和发布/订阅消息传递.消费者可以group_1
通过将其设置group.id
为加入消费者群体(我们说)group_1
.消费者群体也是支持数据的并行消费的一种方式,即同一消费者群体的不同消费者从不同分区并行地消费数据.
除了group.id之外,每个消费者还使用Kafka经纪人识别自己consumer.id
.Kafka使用它来识别特定消费者组的当前ACTIVE消费者.
阅读此文档以获取更多详细信息