Как настроить потребителя kafka для прослушивания сообщений только в заданном диапазоне времени

Question

Я хочу, чтобы мой потребитель kafka слушал сервер kafka только с 8:00 до 20:00.Он не должен слушать запросы, которые выходят из этого временного диапазона.Возможна ли эта конфигурацияЕсли да, то как это сделать.

Я разработал потребитель kafka в Java.

Спасибо.

Answer 1

Kafka не заботится о ваших потребителях, поэтому для этого нет настроек.
Либо заставьте вашего потребителя полностью прекратить потребление за пределами вашего периода времени (подумайте Cron-Job, либо просто не опрашивайте, если он находится вне кадра), либо потребляйтено не обрабатывайте, что увеличит смещение.
Опция fist «продолжит» работу в 8:00, вторая будет игнорировать все, что находится за пределами вашего таймфрейма.Если у вас есть потребитель, его легко реализовать.