При перевыкладке ограничивают рост lag через graceful shutdown, достаточную ёмкость consumers и контролируемую ребалансировку. После запуска очередь догоняют без перегрузки зависимостей.
Что вы делали с отставанием consumer lag при перевыкатке или остановке сервиса?
При перевыкладке ограничивают рост lag через graceful shutdown, достаточную ёмкость consumers и контролируемую ребалансировку. После запуска очередь догоняют без перегрузки зависимостей.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
При перевыкладке ограничивают рост lag через graceful shutdown, достаточную ёмкость consumers и контролируемую ребалансировку. После запуска очередь догоняют без перегрузки зависимостей.
Не подтверждайте необработанные сообщения ради красивой метрики. Оцените скорость поступления и обработки, retention и время догоняния. Масштабирование ограничено числом партиций и возможностями БД; слишком много workers может усилить задержки вместо устранения.