В Kafka сообщения распределяются по партициям топика. При наличии 6 партиций и 6 консюмеров в одной группе каждый консюмер обычно получает ровно одну партицию, то есть нагрузка распределяется равномерно.

Если количество консюмеров уменьшится до 2, то 6 партиций будут распределены между этими двумя консюмерами. Например, один может получить 3 партиции, другой — 3. Важно, что число партиций всегда больше или равно количеству консюмеров, иначе некоторые консюмеры будут простаивать.

Пример распределения:

6 партиций, 6 консюмеров: каждый консюмер читает 1 партицию.
6 партиций, 2 консюмера: консюмер 1 читает партиции 0,1,2; консюмер 2 — 3,4,5.

Такое распределение обеспечивает параллельную обработку данных и балансировку нагрузки между консюмерами.

Kafka: как распределяются сообщения между партициями при 6 партициях и 6 консюмерах? Что если консюмеров станет 2?