apache-kafka - Kafka消费者中groupid和consumerid的区别

标签 apache-kafka kafka-consumer-api

我注意到消费者配置有两个 ID。一个是group.id (必填)第二个是 consumer.id (不是强制性的)。
这两个ID有什么区别?

最佳答案

消费者组是一种 Kafka 抽象,它支持点对点和发布/订阅消息传递。消费者可以通过设置它的 group_1 加入消费者组(让我们说 group.id )。至 group_1 .消费者组也是一种支持数据并行消费的方式,即同一消费者组的不同消费者并行消费来自不同分区的数据。

除了 group.id 之外,每个消费者还使用 consumer.id 向 Kafka 代理标识自己。 . Kafka 使用它来识别特定消费者组的当前 ACTIVE 消费者。

阅读 this documentation更多细节。

关于apache-kafka - Kafka消费者中groupid和consumerid的区别,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34550873/

相关文章:

kotlin - 使用自定义(ConsumerAware)错误处理程序时如何查找和提交?

node.js - kafka 消费者和异步处理程序

apache-kafka - 如果在收到创建消息之前收到更新消息,如何处理kafka消息?

apache-kafka - Consumer Offset 是在 Consumer group level 还是在该 consumer group 内的单个 consumer 管理的?

java - 为什么 Producer.send(record).get() 有效,但 Producer.send(record, callback) 不起作用

java - Kafka 0.10.2 消费者获得大量重复项

java - 无法从 Bluemix Liberty 连接到 BlueMix MessageHub

apache-kafka - kafka-consumer-groups.sh 何时将 CURRENT_OFFSET 显示为 "-"?

scala - Kafka主题创建: Timed out waiting for a node assignment

apache-kafka - 从副本消费