При 5 партициях и 5 consumer'ах один consumer упал: как произойдёт перераспределение нагрузки и сколько займёт восстановление?

Оставшиеся четыре участника группы получат пять partitions: обычно одному достанутся две, остальным по одной. Время зависит от обнаружения сбоя и протокола rebalance.

Короткий ответ

Что ответить на собеседовании

Оставшиеся четыре участника группы получат пять partitions: обычно одному достанутся две, остальным по одной. Время зависит от обнаружения сбоя и протокола rebalance.

Подробный разбор

Ответ с пояснениями

Оставшиеся четыре участника группы получат пять partitions: обычно одному достанутся две, остальным по одной. Время зависит от обнаружения сбоя и протокола rebalance.

При штатном выходе переназначение может начаться быстро; при падении группа сначала должна признать consumer недоступным. Влияют heartbeat/session timeout, max.poll.interval, выбранный group protocol, assignor и время восстановления state. Новому владельцу нужно продолжить с подтверждённого offset, поэтому незакоммиченная работа может повториться. Назвать точные секунды без настроек нельзя. Дополнительная partition увеличивает нагрузку не обязательно ровно вдвое: потоки могут иметь разную интенсивность.

ИИ-помощник для собеседований

Хочешь уверенно проходить собеседования?

Попробуй ИИ-помощник для собеседований: слышит вас и собеседника, анализирует экран, подсказывает ответы в реальном времени, работает без VPN и не попадает в захват экрана.

Подробнее