【发布时间】:2015-04-30 11:58:26
【问题描述】:
当从kafka消费消息时,通常带有组id。但是,SimpleConsumer API只使用clientName。clientName是组id?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
当从kafka消费消息时,通常带有组id。但是,SimpleConsumer API只使用clientName。clientName是组id?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
对于 SimpleConsumer,clientName 只是客户端的标识符。它不是组 ID。其实 SimpleConsumer 中并没有消费组的概念。
请参考documentation - 使用 SimpleConsumer 实现的主要原因是您希望对分区消耗的控制比 Consumer Group 给您的更大。
High Level Consumer有消费群体的概念。
“group.id”字符串定义了这个进程代表的消费者组。
消费者组是一个高级概念,其中特定消息仅由属于同一组的消费者之一消费
【讨论】: