问题描述
因此,我有一个消费群体正在运行,并正在收听来自某个主题的消息。如何将更多消费者实例添加到消费者组?如果这是我收听消息的方式
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 (将#修改为@)