Kafka节点:将消费者添加到消费者组

问题描述

因此,我有一个消费群体正在运行,并正在收听来自某个主题的消息。如何将更多消费者实例添加到消费者组?如果这是我收听消息的方式

let consumer = new kafka.ConsumerGroup(options,topicname);

consumer.on("message",function(message) {
    //process message here
  });

我尝试创建使用者并在选项中包含相同的组名,

new kafka.Consumer(
      client,[
        { topic: topicName}
      ],{
        groupId: groupId
      }
      );

但是当我运行命令时,我看不到它反映在消费者组中

bin/kafka-consumer-groups.sh --describe --group groupname --bootstrap-server localhost:9092

我看到同一个使用者被分配了该主题的不同分区。

如何在创建的现有消费者组中添加更多消费者?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)