问题描述
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 (将#修改为@)