Kafka Consumer - 重置消费者轮询时间

Question

我有一个 Kafka 消费者，其中提到了轮询时间

kafkaConsumer.poll(polltimeinmilliseconds);

我想动态更新轮询计时器。现在我将它设置为一个静态变量，并且轮询时间会更新。

问题是，消费者等待旧计时器完成。即如果旧计时器是 5 分钟，并且如果我将计时器更新为 10（动态），它会在更新到 10 分钟间隔之前适当地等待前 5 分钟。

如何立即重置它。即计时器应立即重置并设置为 10 分钟？

Answer 1

您可以使用wakeup 方法中止长轮询。

唤醒消费者。此方法是线程安全的，特别适用于中止长轮询。在操作中阻塞的线程将抛出 WakeupException。如果没有线程阻塞在一个可以抛出 WakeupException 的方法中，那么对此类方法的下一次调用将改为引发它。