Ce face comanda kafka-consumer-groups.sh –describe
Comanda kafka-consumer-groups.sh --describe este cel mai important instrument de diagnostic operațional pentru aplicațiile care consumă din Kafka. Aceasta compară poziția de citire a aplicației cu ultimul mesaj scris de producători pe fiecare partiție, calculând coloana esențială LAG.
Exemplu Concret: Diagnosticarea decalajului pe grupul ‘serviciu-email’
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--describe \
--group serviciu-email
# Rezultat:
# TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
# comenzi 0 10450 10450 0 worker-1-uuid /10.0.0.12 consumer-app
# comenzi 1 8200 9150 950 worker-2-uuid /10.0.0.13 consumer-app
# comenzi 2 12000 12000 0 worker-3-uuid /10.0.0.14 consumer-appCe indică un LAG ridicat?
Dacă pe partiția 1 valoarea LAG este 950 și continuă să crească, înseamnă că worker-ul respectiv este blocat, prelucrează mesajele mai lent decât ritmul de sosire sau suferă blocaje de rețea/bază de date.
Întrebări & Exemple de Cod:
kafka-consumer-groups.sh –describe: Măsurarea Decalajului (LAG)Ai o nelămurire despre utilizarea comenzii
kafka-consumer-groups.sh –describe: Măsurarea Decalajului (LAG)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.