Validate Kafka

Let us go ahead and validate Kafka by creating a topic and then publishing messages to a topic as well as consuming messages from a topic.

  • Create Kafka Topic

kafka-topics --create --zookeeper bigdataserver-2:2181,bigdataserver-3:2181,bigdataserver-4:2181 --replication-factor 2 --partitions 3 --topic testing

  • Produce the message to the topic

kafka-console-producer --broker-list bigdataserver-5:9092,bigdataserver-6:9092 --topic testing

  • Consume the message from the topic

kafka-console-consumer --bootstrap-server bigdataserver-5:9092,bigdataserver-6:9092 --topic testing --from-beginning

Share this post