Ce face comanda kafka-topics.sh –describe
Comanda kafka-topics.sh --describe oferă o privire transparentă asupra stării interne a fiecărei partiții dintr-un topic. Este instrumentul principal de diagnostic pentru a detecta brokeri căzuți, partitii sub-replicate (under-replicated) sau desincronizări în grupul ISR.
Exemplu Concret: Inspectarea topicului ‘comenzi’
kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic comenzi
# Exemplu ieșire:
# Topic: comenzi TopicId: 4Zp_qQx9... PartitionCount: 3 ReplicationFactor: 3 Configs: min.insync.replicas=2
# Topic: comenzi Partition: 0 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
# Topic: comenzi Partition: 1 Leader: 2 Replicas: 2,3,1 Isr: 2,3,1
# Topic: comenzi Partition: 2 Leader: 3 Replicas: 3,1,2 Isr: 3,1,2
Interpretarea coloanelor afișate
- Leader: ID-ul brokerului responsabil pentru preluarea tuturor scrierilor și citirilor pentru respectiva partiție.
- Replicas: Lista tuturor brokerilor care dețin o copie a partiției, indiferent dacă sunt online sau nu.
- Isr (In-Sync Replicas): Submulțimea replicilor care sunt complet la zi cu brokerul lider. Dacă o replică rămâne în urmă, este eliminată din ISR până recuperează decalajul.
Întrebări & Exemple de Cod:
kafka-topics.sh –describe: Inspectarea Detaliată a TopicelorAi o nelămurire despre utilizarea comenzii
kafka-topics.sh –describe: Inspectarea Detaliată a Topicelorsau 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.