Lag — разница между концом партиции (high watermark/end offset) и текущим committed/position консьюмера; показывает отставание обработки.
Разбор
- Высокий lag → медленные воркеры, мало партиций, инцидент.
- Мониторят per-partition и суммарно по группе.
- Lag=0 не всегда «нет работы» — смотрите end offset рост.
- Алерты на lag — базовый SLO стриминга.
Итог
Lag измеряет, насколько consumer group отстаёт от конца лога.