1)Run the zookeeper on terminal using following command $ bin/zookeeper-server-start.sh config/zookeeper.properties 2) On the new instance of the terminal, run the kafka server $ bin/kafka-server-start.sh config/server.properties 3)RestAPI endpoint for publisher http://localhost:8080/requestAPI/messages 4) On the new instance of the terminal, we can add consumers using given command (Note: In this application, I have already added a listener method, which will be consuming the data from the topics and it will be priniting them on console) $ bin/kafka-console-consumer.sh --topic second_topic --from-beginning --bootstrap-server localhost:9092
-
Notifications
You must be signed in to change notification settings - Fork 0
akshaypatil3096/Kafka-example
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published