Consumer Groups and Rebalancing

Com seis partitions e dois consumers, o assignment observado foi 3/3. Quando um membro morreu, o survivor assumiu as seis partitions depois do rebalance. CURRENT-OFFSET é o checkpoint do group; LOG-END-OFFSET é a cauda produzida; LAG é a diferença entre ambos.

Kafka Streams usa o application.id como group e namespace de tasks/estado. Duas instâncias devem usar o mesmo ID para escalar uma aplicação; IDs diferentes processariam o mesmo input como aplicações independentes.