У Kafka, za raspodelu potrošača između particija jednog topika, koristi se entitet Consumer Group (grupa potrošača). Svaki potrošač u grupi dobija jedinstveni skup particija, što omogućava paralelnu obradu podataka bez dupliranja.

Princip rada:

Svi potrošači sa istim group.id formiraju grupu.
Kafka raspoređuje particije topika između potrošača grupe.
Ako se dodaju ili uklone potrošači, vrši se rebalance.

Na ovaj način, Consumer Group obezbeđuje skalabilnost i balansiranje opterećenja pri čitanju iz topika.

Претходно Следеће