node.js - Kafka-Node：提交前一个后如何同步消费消息

Question

卡夫卡消费者一次被大量消息轰炸，我需要在提交第一个消息后一个接一个地接收它们。我尝试过autoCommit:false，并尝试使用pause()andresume()来接收数据。但是，它仍然不起作用。有没有办法在这个库中实现这一点？

标签： node.jsapache-kafka

Answer 1

您可以使用消费者的属性来限制通过调用方法max.poll.records返回的消息的数量。poll()