卡夫卡长期投票

Question

我正在考虑kafka实现一个低延迟的消息队列,我一直在阅读有关消费者长期轮询的信息.但是,没有关于如何实际使用长轮询的示例,或者您需要设置哪些选项来启用它.如何使用kafka java api启用长轮询？

Answer 1

您不必每次启用它,因为它是kafka使用者的默认行为.您需要在配置中设置的是fetch.wait.max.ms.

两个值对于实现您想要的目标非常重要:

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

在Kafka Consumer Configs中查找更多配置选项

对于像这样的问题,kafka用户邮件列表也是一个很好的选择.