long-polling - 卡夫卡长轮询

Question

我正在寻找 kafka 来实现低延迟消息队列，并且我一直在阅读有关消费者长轮询的信息。但是，没有关于如何实际使用长轮询或需要设置哪些选项才能启用它的示例。如何使用 kafka java api 启用长轮询？

Answer 1

您不必每次都启用它，因为它是 kafka 使用者的默认行为。您需要在配置中设置的是 fetch.wait.max.ms .
两个值对于实现您想要的很重要:

fetch.min.bytes :代理将等待此数量的数据填满，然后再将响应发送给消费者客户端。

fetch.max.wait.ms :代理将在向消费者客户端发送响应之前等待这段时间，除非它有足够的数据来填充响应 ( fetch.message.min.bytes )

一旦达到这些值中的任何一个，就会向消费者发送响应。最长可能的获取请求时间总是 fetch.max.wait.ms .
在 Kafka Consumer Configs 中寻找更多配置选项
对于此类问题，kafka 用户邮件列表也是一个不错的选择。