Jaką jednostkę w Kafka używa się do rozdzielania konsumentów między partycje tego samego topiku?

W Kafka, aby rozdzielić konsumentów między partycje tego samego tematu, używa się encji Consumer Group (grupa konsumentów). Każdy konsument w grupie otrzymuje unikalny zestaw partycji, co umożliwia równoległe przetwarzanie danych bez duplikacji.

Zasada działania:

• Wszyscy konsumenci z tym samym group.id tworzą grupę.
• Kafka rozdziela partycje tematu między konsumentów grupy.
• Jeśli konsumenci są dodawani lub usuwani, następuje rebalance.

W ten sposób, Consumer Group zapewnia skalowalność i równoważenie obciążenia podczas odczytu z tematu.