当消费来自kafka的消息时,通常使用一个组id.But,SimpleConsumer只使用一个clientName.The clientName是组id?

when consume message from kafka,usually with a group id.But,SimpleConsumer just use a clientName.The clientName is group id?

当消费来自kafka的消息时,通常使用组id.But,SimpleConsumer API just use a clientName.The clientName is group id?

对于 SimpleConsumer,clientName 只是客户端的标识符。它不是组 ID。实际上SimpleConsumer中并没有consumer groups的概念。

请参阅 documentation - 使用 SimpleConsumer 实现的主要原因是您希望比 Consumer Groups 更好地控制分区消耗。

High Level Consumer有消费群体的概念

“group.id”字符串定义了此进程代表的消费者组。

Consumer Group 是一个高级概念,其中特定消息仅由属于同一组的一个消费者消费