Apache Kafka

Admin Commands

Kafka administrative operations for cluster monitoring, configuration, and maintenance.

5 commands

Pro Tips

Monitor under-replicated partitions regularly for cluster health.

Use kafka-log-dirs.sh to check disk usage across brokers.

Some broker configs require restart to take effect.

$ kafka-metadata.sh --snapshot /var/kafka/logs/__cluster_metadata-0/00000000000000000000.log --command describe

Show cluster metadata.

$ kafka-configs.sh --describe --entity-type brokers --entity-name 0 --bootstrap-server localhost:9092

Show broker configuration.

$ kafka-topics.sh --describe --under-replicated-partitions --bootstrap-server localhost:9092

Find under-replicated partitions.

$ kafka-log-dirs.sh --describe --bootstrap-server localhost:9092

Show log directory info.

$ kafka-run-class.sh kafka.tools.GetOffsetShell --topic my-topic --bootstrap-server localhost:9092

Get partition offsets.