session.timeout.ms — сколько ждать heartbeat от фонового потока: ловит «мёртвый» процесс. max.poll.interval.ms — максимум времени между вызовами poll(): ловит «живой, но застрявший» в обработке.
А ещё Признак проблемы — бесконечные ребалансы и повторная обработка тех же сообщений
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Heartbeat-поток шлёт сигналы «я жив» отдельно от обработки; если их нет дольше session.timeout.ms — группа считает consumer упавшим и запускает rebalance. Но даже при живых heartbeat consumer обязан регулярно звать poll(): если обработка одной пачки заняла больше max.poll.interval.ms, брокер решает, что consumer завис, и исключает его из группы (тоже rebalance, плюс возможные дубли). Поэтому медленную обработку лечат уменьшением max.poll.records или выносом работы, а не раздуванием таймаутов.
Один верный вариант. Подумайте, потом откройте ответ.
Consumer lag и его причины, ребаланс и безопасный commit, poison-сообщения, ZooKeeper → KRaft, schema evolution, изменения partitions и ключевые метрики.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto