KafkaJS在与Kafka和KafkaConnect进行初始连接后重新连接时抛出错误？

问题的原因可能是KafkaJS在接收到Kafka Connect的响应时间时已经重新连接，从而与Kafka解除了连接。为了解决这个问题，可以使用KafkaJS的maxWaitTimeInMs选项来增加等待响应的时间。

以下是代码示例：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({
  brokers: ['localhost:9092'],
  retry: {
    maxRetryTime: 30000,
  },
  connectionTimeout: 3000,
  requestTimeout: 3000,
  maxWaitTimeInMs: 5000 // 设置等待响应的时间
})

const consumer = kafka.consumer({ groupId: 'test-group' })

async function run() {
  await consumer.connect()
  await consumer.subscribe({ topic: 'test-topic', fromBeginning: true })

  await consumer.run({
    eachMessage: async ({ topic, partition, message }) => {
      console.log({
        value: message.value.toString(),
      })
    },
  })
}

run().catch(console.error)