Verifying Kafka HA Configuration

Last Updated : Nov 05, 2025 |

Procedure

  1. Execute $POM_HOME/bin/enableKafkaHA.sh.
  2. Check if zookeeper and Kafka servers are up and running on all POM systems.

    On external Kafka server verify using Java Virtual Machine Process Status Tool (jps).

  3. Check if Kafka topics are created successfully. 
    $KAFKA_HOME/bin/kafka-topics.sh --bootstrap-server <hostname>:9093 --command-config $KAFKA_HOME/config/client.properties --list
  4. If topics are created, verify that replicas of all topic partitions are distributed over all the brokers. 
    $KAFKA_HOME/bin/kafka-topics.sh --bootstrap-server <hostname>:9093 --command-config $KAFKA_HOME/config/client.properties --describe
  5. Stop the broker (Kafka server) which is leader for one of the topic partition and check leader is changing for that topic partition and same broker id is not getting listed in replicas for all the partitions.
  6. Start the broker again and check broker id is getting listed in Isr replicas for all the partitions.