【问题标题】:when consume message from kafka,usually with a group id.But,SimpleConsumer just use a clientName.The clientName is group id?当使用来自 kafka 的消息时,通常使用组 ID。但是,SimpleConsumer 只使用客户端名称。客户端名称是组 ID?
【发布时间】:2015-04-30 11:58:26
【问题描述】:

当从kafka消费消息时,通常带有组id。但是,SimpleConsumer API只使用clientName。clientName是组id?

【问题讨论】:

    标签: apache-kafka kafka-consumer-api


    【解决方案1】:

    对于 SimpleConsumer,clientName 只是客户端的标识符。它不是组 ID。其实 SimpleConsumer 中并没有消费组的概念。

    请参考documentation - 使用 SimpleConsumer 实现的主要原因是您希望对分区消耗的控制比 Consumer Group 给您的更大。

    High Level Consumer有消费群体的概念。

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

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2023-03-21
      • 2014-04-24
      • 2011-08-11
      • 1970-01-01
      相关资源
      最近更新 更多