Wednesday 28 September 2022

Let's Kafka

I thought of documenting my Kafka learning process so one might find this helpful. 

How to start the broker:

$ ./zookeeper-server-start.sh -daemon /home/bershath/apps/kafka/kafka_2.13-3.1.0.redhat-00004/config/zookeeper.properties

#Verify the existence of zookeeper

$ jcmd | grep zookeeper

$ ./kafka-server-start.sh -daemon /home/bershath/apps/kafka/kafka_2.13-3.1.0.redhat-00004/config/server.properties

#Verify Kafka is running

$ jcmd | grep kafka


How to send a few messages and receive them to verify the installation

$ ./kafka-topics.sh --bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic test

$ ./kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic test

$ ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

$ ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning