Catatan Command Apache Kafka di Ubuntu Server 18.04

Hanya sebagai pengingat saja.

List all topic
kafka_dir/bin/kafka-topics.sh --list --zookeeper zklist:port

Detail topic
kafka_dir/bin/kafka-topics.sh --describe --zookeeper zklist:port --topic [topic-name]

Membuat topic
kafka_dir/bin/kafka-topics.sh --create --zookeeper zklist:port --replication-factor [x] --partitions [y] --topic [topic-name]

Menghapus topic
kafka_dir/bin/kafka-topics.sh --delete --zookeeper zklist:port --topic [topic-name]

Konfigurasi waktu rebalance
leader.imbalance.check.inverval.second
(default 5 menit)

Rebalance manual
kafka_dir/bin/kafka-preferred-replica-election.sh --zookeeper zklist:port

Melihat daftar broker di cluster
Melalui server dedicated zookeeper
zk_dir/bin/zkCli.sh -server addr:port
ls /brokers/ids # daftar broker aktif
ls /brokers/topics # daftar topic
get /brokers/id/[x] # detail broker dengan id [x]
deleteall /brokers/topics/[abc] # konfigurasi ulang topic [abc]

Mengaktifkan JMX Monitoring
$KAFKA_JMX_OPTS JMX_PORT=[your_port_number] ./kafka-server-start.sh -daemon ../config/server.properties