Выбор ответа Junior Kafka спрашивают часто обновлено
Что такое consumer lag
Вопрос
В партиции последний оффсет 10 500, группа закоммитила оффсет 9 700. Что это значит?
Попробуйте сами
Выберите вариант, и откроется разбор.
Показать ответ и разбор
Коротко
Правильный ответ: Lag 800 сообщений: группа ещё не обработала 800 сообщений этой партиции. Lag = log end offset - committed offset.
Варианты ответа
- Lag 800 сообщений: группа ещё не обработала 800 сообщений этой партицииправильный ответ
- Потеряно 800 сообщений: они удалены до того, как группа их прочитала
- В партиции сейчас хранится 9 700 сообщений, остальные удалены по retention
- Группа обработала 800 сообщений с момента последней ребалансировки
Разбор
Lag = log end offset - committed offset. Сообщения не потеряны, они ждут обработки (если не успеют удалиться по retention). Число сообщений в партиции зависит от retention, а не от оффсета группы. Растущий lag значит, что консьюмеры не успевают, и нужны оптимизация, больше консьюмеров (до числа партиций) или больше партиций.
Ответьте сами, а не прочитайте
В тренажёре вопрос попадёт в повторения и вернётся, когда начнёт забываться. Плюс билеты с зачётом: 20 вопросов, не больше 2 ошибок.