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

qq24tv8q 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(396)

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));

});

apache-kafka node.js kafka-producer-api

来源：https://stackoverflow.com/questions/53997470/node-rd-kafka-repeats-delivery-reports-from-beginning-for-each-message

1条答案

按热度按时间

axr492tv1#

为了 delivery-report 事件有一个 once 绑定，每个消息只传递一个传递报告。

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

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

});

赞(0）回复(0）举报 2021-06-07

我来回答

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

1条答案

相关问题

热门标签

最新问答