我的kafka-node客户端仅从零分区读取消息

问题描述

我有一个简单的kafka-node ConsumerGroup设置，如下所示-

'use strict';

const kafka = require('kafka-node');
const ConsumerGroup = kafka.ConsumerGroup;
const topic = 'topic-name';
const kafkaHost = 'broker:9092';

const consumerOptions = {
  kafkaHost: kafkaHost,groupId: 'kafka-node',sslOptions: { rejectUnauthorized: false },sasl:{  mechanism: 'plain',username: process.env.SASL_USERNAME,password: process.env.SASL_PASSWORD },sessionTimeout: 15000,protocol: ['roundrobin'],fromOffset: 'latest',commitOffsetsOnFirstJoin: true,};

console.log("Connecting to Kafka on :",kafkaHost);

const consumerGroup = new ConsumerGroup(consumerOptions,topic);

consumerGroup.on('message',function (message) { console.log('Message >>> \n',message)});

consumerGroup.on('error',(error) => { console.log('Error >>> \n',error)});

当我运行此代码时，它正确地订阅了在零分区上发布的消息，并且没有读取发布到任何其他分区上的消息。可能是什么问题？ I am following the examples mentioned here

解决方法

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

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

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