Configuring Kafka with windows:
The commands for configuring kafka are same for both windows and linux, replace .bat with .sh for accessing in linux environment.Step 1:
Download Apache Kafka binaries and unzip it under say D:/kafka<version>
Step 2:
Go to command prompt and run the kafka commands from windows folder under kafka<version>:
cd kafka<version>/bin/windows
Run Zookeper server:
zookeeper-server-start.bat ../../config/zookeeper.properties
Run Kafka server:
kafka-server-start.bat ../../config/server.properties
Accessing Kafka via command line utilities:
The commands for accessing kafka are same for both windows and linux, replace .bat with .sh for accessing in linux environment.Create a topic:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
List the topics created:
kafka-topics.bat --list --zookeeper localhost:2181
Send some message via producer program:
kafka-console-producer.bat --broker-list localhost:9092 --topic test
start a consumer program in a different cmd to see the messages sent from producer:
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning
For newer versions of kafka, below command needs to be used by default for console-consumer program:
kafka-console-consumer
.bat --bootstrap-server localhost:9092 --topic
test
--from-beginning
To publish/subscribe Kafka messages via Java API, please refer - Using Java API for publish/consume Kafka messages