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

lrl1mhuk 于 2021-06-08 发布在 Kafka

关注(0)|答案(1)|浏览(600)

我有一个Kafka消费者，上面提到了投票时间

kafkaConsumer.poll(polltimeinmilliseconds);

我想动态更新轮询计时器。现在我将其设置为一个静态变量，轮询时间将更新。
问题是，消费者等待旧计时器完成。i、 e如果旧的计时器是5分钟，并且如果我将计时器更新为10（动态地），那么它将在更新为10分钟间隔之前适时地等待前5分钟。
如何立即重置。i、定时器应该立即重置并设置为10分钟？

1条答案

您可以使用 wakeup 方法。
唤醒消费者。此方法是线程安全的，特别适用于中止长轮询。在操作中阻塞的线程将引发wakeupexception。如果某个方法中没有线程阻塞，而该方法可能引发wakeupexception，那么对该方法的下一次调用将引发它。