Ребаланс — перераспределение партиций при входе или выходе участника группы. При eager-протоколе все отдают партиции и ждут нового назначения — обработка стоит; незакоммиченная работа повторится.
А ещё Коммитить обработанное в onPartitionsRevoked
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Он случается при добавлении/падении consumer, timeout heartbeat, изменении partitions. Во время rebalance обработка временно останавливается, partitions revoked у consumers; обработчик rebalance должен зафиксировать прогресс по отозванным partitions и корректно остановить in-flight работу.
Consumer lag и его причины, ребаланс и безопасный commit, poison-сообщения, ZooKeeper → KRaft, schema evolution, изменения partitions и ключевые метрики.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto