我正在寻找一种“低成本”的方法来在我不主动进行投票时让消费者保持活力。即,仍在处理上次轮询的记录,并且我不希望消费者连接超时。

一些看起来很有希望的功能:

  • wakeup
  • commitAsync

  • 在每种情况下,这都是 API 的非标准用法,所以我不确定这是否是一种合理/合理的方法。

    RE:将连接超时设置得更高 - 我希望消费者在它被楔入时超时。我的问题与一个部分有关,在该部分中我获取了一组记录并且单独的线程正在处理它们。

    最佳答案

    documentation 似乎建议你应该调用 pause() 然后继续主动轮询。如果您在暂停时调用 poll(),则不会返回任何内容。


    pause() 的文档证实了这一点:

    关于java - 使用 Kafka 让消费者保持活力,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/43722587/

    10-12 23:46