微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决卡夫卡节点不断断开连接,并重新连接“卡夫卡生产者错误: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 举报,一经查实,本站将立刻删除。