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