узел 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));

});