SYSTEM ATLASЗагрузка материала

Consumer Lag

Consumer Lag

Разница между опубликованными и обработанными событиями показывает отставание потребителя.

Простыми словами

Представьте конвейер, где новые коробки приходят быстрее, чем рабочий успевает их разбирать. Consumer lag показывает отставание обработчика от конца потока, поэтому рост лага сигнализирует о нехватке мощности, ошибках или слишком медленной обработке.

Механизм действия

Сначала проверяют, есть ли исходное условие из определения. Затем смотрят, как оно влияет на структуру компонентов, потоки данных, ограничения и действия участников. Если эту связь не удаётся наблюдать, принцип не стоит использовать как готовое объяснение.

Пример в работе

Нерабочий подход

Игнорировать механизм и реагировать только на отдельный симптом.

Системный подход

Зафиксировать условия, применить механизм и проверить результат по наблюдаемому сигналу.

Ограничения

«Consumer Lag» объясняет только часть происходящего в области «Распределенные системы». Сам принцип не говорит, насколько сильным будет эффект в вашем случае, и не заменяет измерения. При другом масштабе, среде или временном горизонте результат может отличаться.

Источник

Apache Software Foundation. Apache Kafka Consumer Metrics. 2026.

Первоисточник