Встречается на собеседованиях • сегодня

Что произойдет, если появится еще один Consumer, при неизменном количестве Partition

При добавлении нового Consumer в Consumer Group с неизменным количеством Partition произойдет ребалансировка. Kafka перераспределит Partitions между Consumer'ами:

  1. Если Partitions > Consumers - новый Consumer получит часть Partitions от других
  2. Если Partitions == Consumers - новый Consumer останется без работы (не получит Partitions)
  3. Если Partitions < Consumers - некоторые Consumer'ы останутся без Partitions

Пример с 3 Partitions и 2 Consumer'ами:

java
// Было:
Consumer1: Partition0, Partition1
Consumer2: Partition2

// Добавили Consumer3:
Consumer1: Partition0
Consumer2: Partition1 
Consumer3: Partition2

Важно: ребалансировка вызывает кратковременную паузу в обработке сообщений. Для минимизации влияния используйте CooperativeStickyAssignor.

Sophi
Софи собрала все вопросы. Тренируйся и получай
офферы быстрее!
Попробовать бесплатноArrow

Следующий вопрос

Это единственный вопрос по вашему фильтру

как отвечать на вопрос
пример собеседования
фреймворки на собеседовании
типичные вопросы junior
интервью вопросы и ответы