Skip to content

ReplicaVerificationTool

ReplicaVerificationTool is a command-line application for kafka-replica-verification to perform replica verification.

Executing Application

main prints out the following INFO message to the logs:

Getting topic metadata...

main createAdminClient (with the brokers in --broker-list option) for topics metadata and broker info.

main creates TopicPartitionReplicas for the topics.

main prints out the following DEBUG message to the logs:

Selected topic partitions: [topicPartitionReplicas]

main groups partitions per broker and prints out the following DEBUG message to the logs:

Topic partitions per broker: [brokerToTopicPartitions]

main groups partitions per replica to count the number of replicas and prints out the following DEBUG message to the logs:

Expected replicas per topic partition: [expectedReplicasPerTopicPartition]

main creates a consumer config.

main creates ReplicaFetchers for every replica broker and starts them all.

ReplicaFetchers run until termination (Ctrl-C). main prints out the following INFO message to the logs:

Stopping all fetchers