каждые три секунды дженкинсом (отдельный вопрос о корректности такого решения, но им нравится). Однако в выводе kafka-consumer-groups по их группе я вижу, что оффсет топика двигается раз в примерно 30 секунд с варнингом "consumer group 'group_name' is rebalancing.
Я так понимаю, как раз ребалансировка и блокирует чтение. А вот что этот ребаланс может вызывать?
Именно перезапуск джобы чтения
Обсуждают сегодня