如何在kafka js消费者中增加消息之间的延迟

Question

我正在收听kafka js中的一个消费者，消息来得太快了，我想添加延迟，比如每5秒10条消息，我怎么才能在不丢失队列中的任何消息的情况下实现这一目标。

Answer 1

您可以暂停特定主题/分区上的消费，稍等片刻然后继续消费。如果你的目标是处理消息爆发，这应该是可以的，只是检查是否有永远赶不上的风险(即，如果生产者发送消息的速度总是比你消费消息的速度快)。