Как заранее увидеть, что начинает копиться очередь в Kafka, чтобы это не влияло на пользователей?

Наблюдайте consumer lag, возраст самого старого необработанного события и разницу скоростей записи и обработки. Тренд роста часто важнее одного абсолютного значения lag.

Разбивайте показатели по partitions и группам: общий график может скрыть одну перегруженную partition. Следите за retries, длительностью обработки, rebalances и доступностью consumers. Alert привязывайте к допустимой задержке бизнес-сценария. Метрика количества сообщений не заменяет оценку времени ожидания, особенно при разной тяжести задач.