Lag — разница между последним записанным offset и зафиксированным группой: сколько сообщений ещё не обработано. Главный показатель здоровья потребителя.
А ещё Инструменты: kafka-consumer-groups, Burrow, экспортеры Prometheus
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Небольшие колебания нормальны, а вот устойчивый рост означает, что обработка не поспевает за записью, и именно на него имеет смысл настраивать оповещение. Опасность не только в задержке: если отставание превысит срок хранения сообщений, необработанные записи будут удалены и потеряны безвозвратно.
Один верный вариант. Подумайте, потом откройте ответ.
Consumer lag и его причины, ребаланс и безопасный commit, poison-сообщения, ZooKeeper → KRaft, schema evolution, изменения partitions и ключевые метрики.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto