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

如何解决我的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