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
akshaypatil3096/Kafka-example
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
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