Kafka消费者轮询间隔

Question

我有一个Kafka主题，并为其附加了1个消费者(主题只有1个分区)。现在对于超时，我使用默认值(心跳:3秒，会话超时:10秒，轮询超时:5分钟)。

根据留档，轮询超时定义消费者必须在其他代理将该消费者从消费者组中删除之前处理消息。现在假设，消费者只需1分钟即可完成处理消息。

现在我有两个问题

a) Now will it call poll only after 5 mins or it will call poll() as soon as it finishes processing. 
b) Also, suppose consumer is sitting idle for sometime, then what would be the frequency of polling i.e. at what interval consumer will poll the broker for message? Will it be poll timeout or something else?

Answer 1

我假设您所指的5分钟设置是＜code＞max.poll.interval。ms＜/code＞，而不是轮询超时。

还有，我假设你是从爪哇打电话给Kafka；如果你使用不同的语言，答案可能会不同。

轮询超时是传递给 Kafka 消费者轮询 （） 方法的值。这是 poll（） 方法在您调用它之后将阻止的最长时间。

最大轮询间隔为5分钟，这意味着您必须在轮询（）的最后一次调用返回后的5分钟结束之前再次调用轮询（）。如果不这样做，您的消费者将断开连接。

所以你的问题：

a）现在它只会在5分钟后调用轮询，或者它会在完成处理后立即调用轮询（）。

这完全取决于你。你是那个在你自己的代码中做召唤的人。你应该有一个循环来调用 poll（）。

b)此外，假设消费者闲置了一段时间，那么轮询的频率是多少，即消费者以什么间隔轮询代理的消息？会不会是轮询超时或者别的什么？

使用者（即您自己的应用程序代码）不应该处于空闲状态，而应该处于循环中。在此循环中，调用 poll（），然后处理事件（1 分钟），然后再次调用 poll（）。