Ce entitate din Kafka este utilizată pentru a distribui consumatorii între partițiile aceluiași topic?

În Kafka, pentru a distribui consumatorii între partițiile aceluiași topic, se utilizează entitatea Consumer Group (grup de consumatori). Fiecare consumator din grup primește un set unic de partiții, ceea ce permite procesarea paralelă a datelor fără duplicare.

Principiul de funcționare:

• Toți consumatorii cu același group.id formează un grup.
• Kafka distribuie partițiile topicului între consumatorii grupului.
• Dacă consumatorii sunt adăugați sau eliminați, are loc o redistribuire.

Astfel, Consumer Group asigură scalabilitate și echilibrare a încărcăturii la citirea din topic.