момент консьюмер перестает читать сообщения, лаг накапливается. При этом нет ошибок консьюмера ни в логах Кафка, ни в логах консьюмера. Перезапуск консьюмера не помогает, чтение включается само по себе.
На том же топике другое приложение(тот же код, другая группа) читает сообщения без ошибок.
1. Пробовали менять группу - не помогло.
2. Пробовали воспроизвести ошибку в тесте - не получилось.
3. В логах, при включенном аудите, нет ничего за что можно привязаться. На момент остановки чтения вообще нет логов касательно этой группы или топика.
Как можно отдебажить проблему?
включить более глубокий уровень логирования. INFO, DEBUG. На INFO по хорошему такое должно быть уже видно. Проще всего включить в приложении и там наверняка будет что-то написано.
вот как раз уровень дебаг включен ( и на сервере и на приложении. Логов нет совсем, пусто. В приложении тоже самое: пустота, ждет сообщения
такого быть не может. смотрите настройки логирования. на INFO там уже будут коннекты. аутентификации и прочее.
пойду рыть, может где еще не включил дебаг, но вроде везде стоит в конфиге логгера. Пока есть только логи успешной аутентификации.
Обсуждают сегодня