Skip to content

Kafka Command Set

Overview

  • Verification baseline: Kafka 3.6.x CLI (bin/ scripts)
  • Broker static config: Kafka Configuration

Cluster & Broker

Broker registration (ZK mode)

bin/zookeeper-shell.sh zk1:2181 ls /brokers/ids

Dynamic broker config

bin/kafka-configs.sh --bootstrap-server broker:9092 \
  --entity-type brokers --entity-name 0 --describe

Topics

bin/kafka-topics.sh --bootstrap-server broker:9092 \
  --create --topic orders --partitions 6 --replication-factor 3

bin/kafka-topics.sh --bootstrap-server broker:9092 \
  --describe --topic orders

Producer / Consumer

bin/kafka-console-producer.sh --bootstrap-server broker:9092 --topic orders

bin/kafka-console-consumer.sh --bootstrap-server broker:9092 \
  --topic orders --from-beginning --group debug-consumer

Consumer Groups

bin/kafka-consumer-groups.sh --bootstrap-server broker:9092 \
  --describe --group my-app

Log Dirs

bin/kafka-log-dirs.sh --bootstrap-server broker:9092 \
  --describe --topic-list orders