卡夫卡节点不断断开连接,并重新连接“卡夫卡生产者错误:NestedError refreshBrokenMetadata”

问题描述

nodejs服务器以pm2作为一个实例分支启动。

我的卡夫卡选项:

export const kafkaTopics = ['chat'];
export const kafkaOptions: ConsumerGroupOptions = {
  kafkaHost,groupId: 'test-chat',batch: undefined,sessionTimeout: 15000,protocol: ['roundrobin'],encoding: 'utf8',fromOffset: 'latest',outOfRangeOffset: 'earliest',};

客户:

kafkaClient = new Client({
  kafkaHost,idleConnection: 24 * 60 * 60 * 1000,});

制作人:

kafkaConsumer = new ConsumerGroup(options,topics);

消费者:

kafkaProducer = new HighLevelProducer(kafkaClient);
nestedError: refreshMetadata Failed
Kafka producer error: nestedError: refreshbrokenMetadata

任何建议为何会不断发生?

解决方法

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

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

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