node rd kafka 为每条消息从头开始重复传递报告

Question

delivery-report 每次生成的每条消息都会调用事件，并从头开始提供送达报告。例如，我们将获得第一条消息的偏移量为 1 的发送报告。对于第二条消息，我们将得到两个偏移量为 2 的传递报告。对于第三条消息，我们将得到 3 个偏移量为 3 的传递消息，依此类推。

producer.on('delivery-report', function (err, report) {

   console.log("delivery report received");
   console.log('delivery-report: ' + JSON.stringify(report));

});

Answer 1

对于 delivery-report 事件，有一个 once 绑定，它只为每条消息发送一份送达报告。

producer.once('delivery-report', function (err, report) {

   console.log("delivery report received");
   console.log('delivery-report: ' + JSON.stringify(report));

});