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

Принцип работы:

Все консьюмеры с одинаковым group.id формируют группу.
Kafka распределяет партиции топика между консьюмерами группы.
Если консьюмеры добавляются или уходят, происходит ребалансировка.

Таким образом, Consumer Group обеспечивает масштабируемость и балансировку нагрузки при чтении из топика.

Какую сущность в Kafka используют для распределения консьюмеров между партициями одного топика?