KafkaJS生产者仅因事务而断开连接

出现这个问题的原因是在KafkaJS生产者启用了事务，并且在事务完成之前出现了连接断开的情况。解决这个问题的方法是可以使用“uncaughtException”处理函数来处理未捕获的异常，然后在此处关闭生产者。具体的代码实现如下所示：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({ clientId: 'my-app', brokers: ['localhost:9092'] })

const producer = kafka.producer({ idempotent: true })

producer.transaction().then(async () => { // Add your produce logic here await producer.send({ topic: 'my-topic', messages: [{ value: 'Hello KafkaJS' }] }) await producer.commit() }).catch(async () => { await producer.abortTransaction() producer.disconnect() })

process.on('uncaughtException', (error) => { console.error('Error caught in uncaughtException handler:', error) producer.disconnect() })