-
Download the following kafka server from the following link: https://kafka.apache.org/quickstart -> https://www.apache.org/dyn/closer.cgi?path=/kafka/3.2.0/kafka_2.12-3.2.0.tgz
-
Unzip the file using the following command:
tar -xzf kafka_2.12-3.2.0.tgz
-
After unzipping the file go to the file
server.properties
and uncomment thelisteners
and the change thelog.dirs
, In the zookeeper.properties change thedataDir
to the local path -
Use the jdk 11 for the kafdrop setup
-
Download the view kafdrop from, https://github.com/obsidiandynamics/kafdrop/releases, Current version: https://github.com/obsidiandynamics/kafdrop/releases/tag/3.30.0
-
Use the starter_kafka.bat for getting started in the local
-
Kafdrop will be running in the port
9001
-
Cmd to bring the zookeeper server up:
bin/windows/zookeeper-server-start.bat config/zookeeper.properties
-
Cmd to bring the kafka server up:
bin/windows/kafka-server-start.bat config/server.properties
-
Cmd to create a topic:
bin/windows/kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
-
Cmd to enable the producer template:
bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic test
-
Cmd to enable the consumer template:
bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
-
Cmd to bring the zookeeper server up:
bin\windows\zookeeper-server-start.bat config/zookeeper.properties
-
Cmd to bring the kafka server up:
bin\windows\kafka-server-start.bat config/server.properties
-
Cmd to create a topic:
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
-
Cmd to enable the producer template:
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
-
Cmd to enable the consumer template:
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
-
bin\windows\kafka-topics.bat --zookeeper localhost:2181 --topic test --delete
-
delete.topic.enable=true in the server.properties file
-
Kafdrop Command to bring the server up for testing on port 9001,
D:\Applns\openlogic-openjdk-11.0.8+10-windows-x64\openlogic-openjdk-11.0.8+10-win-x64\bin\java -jar kafdrop-3.30.0.jar --server.port=9001 --management.server.port=9001
-
After bringing the kafdrop up use the link below for navigation http://localhost:9001/