我正在寻找一种“低成本”的方法来在我不主动进行投票时让消费者保持活力。即,仍在处理上次轮询的记录,并且我不希望消费者连接超时。
一些看起来很有希望的功能:
在每种情况下,这都是 API 的非标准用法,所以我不确定这是否是一种合理/合理的方法。
RE:将连接超时设置得更高 - 我希望消费者在它被楔入时超时。我的问题与一个部分有关,在该部分中我获取了一组记录并且单独的线程正在处理它们。
最佳答案
documentation 似乎建议你应该调用 pause()
然后继续主动轮询。如果您在暂停时调用 poll()
,则不会返回任何内容。
pause()
的文档证实了这一点:
关于java - 使用 Kafka 让消费者保持活力,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/43722587/