kafka-consumer-groups.sh –list: Monitorizarea Grupurilor de Consumatori în Apache Kafka

Afișează toate ID-urile grupurilor de consumatori înregistrate pe cluster și starea lor de execuție.

Sintaxă
kafka-consumer-groups.sh --bootstrap-server <host:port> --list

Ce face comanda kafka-consumer-groups.sh –list

Comanda kafka-consumer-groups.sh --list scanează topicul intern __consumer_offsets și returnează identificatorii unici ai tuturor grupurilor de consumatori care au comis offset-uri sau care rulează activ pe cluster.

Exemplu Concret: Listarea grupurilor și a stării acestora
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list --state

# Ieșire tipică:
# GROUP                      STATE
# procesator-facturi-prod    Stable
# serviciu-notificari-push   Stable
# sincronizare-search-index  Empty

Stările posibile ale unui grup

  • Stable: Toți membrii grupului sunt conectați și partițiile sunt asignate stabil fără rebalansare.
  • PreparingRebalance: Un nou membru s-a conectat sau un membru a căzut; grupul redistribuie partițiile.
  • Empty: Grupul nu are instanțe active conectate, însă deține offset-uri comise păstrate pe disc.
  • Dead: Grupul a fost șters sau metadatele au expirat.
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: kafka-consumer-groups.sh –list: Monitorizarea Grupurilor de Consumatori

Ai o nelămurire despre utilizarea comenzii kafka-consumer-groups.sh –list: Monitorizarea Grupurilor de Consumatori sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.