Kafka Consumer - Сброс времени опроса потребителей

Question

У меня есть Kafka Consumer со временем опроса, указанным как

kafkaConsumer.poll(polltimeinmilliseconds);

Я хотел бы динамически обновить таймер опроса.Прямо сейчас я установил это в статическую переменную, и время опроса обновляется.

Проблема в том, что потребитель ожидает завершения работы старого таймера.то есть, если старый таймер был 5 минут, и если я обновляю таймер до 10 (динамически), он должным образом ждет первые 5 минут, прежде чем обновлять с интервалом в 10 минут.

Как мне немедленно сбросить его.то есть таймер должен быть сброшен и сразу установлен на 10 минут?

Answer 1

Вы можете прервать длинный опрос, используя метод wakeup.

Разбудить потребителя.Этот метод является поточно-ориентированным и особенно полезен для прерывания длинного опроса.Поток, блокирующий операцию, выдаст исключение WakeupException.Если ни один поток не блокирует метод, который может вызвать исключение WakeupException, следующий вызов такого метода вызовет его.