kafka节点不断断开连接并重新连接“kafka producer error:nestederror refreshbrokenmetadata”

np8igboo  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(529)

nodejs服务器以pm2作为一个单示例fork启动。
我的Kafka选择:

  1. export const kafkaTopics = ['chat'];
  2. export const kafkaOptions: ConsumerGroupOptions = {
  3. kafkaHost,
  4. groupId: 'test-chat',
  5. batch: undefined,
  6. sessionTimeout: 15000,
  7. protocol: ['roundrobin'],
  8. encoding: 'utf8',
  9. fromOffset: 'latest',
  10. outOfRangeOffset: 'earliest',
  11. };

客户:

  1. kafkaClient = new Client({
  2. kafkaHost,
  3. idleConnection: 24 * 60 * 60 * 1000,
  4. });

制作人:

  1. kafkaConsumer = new ConsumerGroup(options, topics);

消费者:

  1. kafkaProducer = new HighLevelProducer(kafkaClient);
  1. NestedError: refreshMetadata failed
  2. Kafka producer error: NestedError: refreshBrokenMetadata

有什么建议为什么会这样吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题