kafka-metadata-shell.sh: Inspecția Metadatelor Quorum KRaft în Apache Kafka

Ce este kafka-metadata-shell.sh

Odată cu eliminarea dependenței de Apache ZooKeeper și adoptarea protocolului intern KRaft (Kafka Raft Metadata Mode), întregul catalog de configurare, brokeri și partiții este menținut într-un topic intern special numit @metadata. Utilitarul kafka-metadata-shell.sh oferă o interfață similară unui sistem de fișiere (cu comenzi ls, cat, cd) pentru a inspecta direct starea consensului KRaft dintr-un snapshot.

# Lansarea shell-ului pe fișierul de snapshot
kafka-metadata-shell.sh --snapshot /var/lib/kafka/data/__cluster_metadata-0/00000000000000000000.log

# În interiorul shell-ului interactiv:
>> ls /
brokers  features  local  metadataQuorum  topics
>> ls /brokers
1  2  3
>> cat /brokers/1/registration
{"rack": null, "fenced": false, "inControlledShutdown": false, ...}

Când este utilizat?

Este un instrument avansat de diagnosticare folosit în incidente de producție, când clusterul are probleme de quorum, partajare de rețea sau coruperi de discuri locale.