I am writing a shell script to monitor kafka brokers.
I have gone through some links and found that if ZooKeeper contains a list of brokers, and if, in this list, the IP address is present, then a kafka broker is running.
I want a command that I can use in my shell script to get the broker list and check whether kafka is running.
Is there any curl
command to get the kafka cluster status like elasticsearch?
A Kafka cluster has exactly one broker that acts as the Controller.
There is only 1 controller at a time.
you can use kafka-manager, an open-source tool powered by yahoo. Show activity on this post. This will list all of the brokers with their id and the beginning offset.
If you are looking for the Kafka cluster broker status, you can use zookeeper cli to find the details for each broker as given below: ls /brokers/ids returns the list of active brokers IDs on the cluster. get /brokers/ids/<id> returns the details of the broker with the given ID.
This command will give you the list of the active brokers between brackets:
./bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids
Alternate way using Zk-Client:
If you do not prefer to pass arguments to ./zookeeper-shell.sh
and want to see the broker details from Zookeeper CLI, you need to install standalone Zookeeper (As traditional Kafka do not comes up with Jline JAR).
Once you install(unzip) the standalone Zookeeper,then:
Run the Zookeeper CLI: $ zookeeper/bin/zkCli.sh -server localhost:2181
#Make sure your Broker is already running
If it is successful, you can see the Zk client running as:
WATCHER::
WatchedEvent state:SyncConnected type:None path:null [zk: localhost:2181(CONNECTED) 0]
$ ls /brokers/ids
# Gives the list of active brokers
$ ls /brokers/topics
#Gives the list of topics
$ get /brokers/ids/0
#Gives more detailed information of the broker id '0'
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With