Коя същност в Kafka се използва за разпределяне на потребителите между партициите на една и съща тема?

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

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

• Всички потребители с еднакъв group.id формират група.
• Kafka разпределя партициите на темата между потребителите на групата.
• Ако се добавят или премахват потребители, се извършва ребалансиране.

По този начин, Consumer Group осигурява мащабируемост и баланс на натоварването при четене от темата.