如何解决我的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 举报,一经查实,本站将立刻删除。