-
Start Zookeeper Server
sh bin/zookeeper-server-start.sh config/zookeeper.properties
-
Start Kafka Server / Broker
sh bin/kafka-server-start.sh config/server.properties
-
Create topic
sh bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic NewTopic --partitions 3 --replication-factor 1
-
list out all topic names
sh bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
-
Describe topics
sh bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic NewTopic
-
Produce message
sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic NewTopic
-
Consume message
sh bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning
-
Notifications
You must be signed in to change notification settings - Fork 0
pranay-sharma793/Kafka-Messenger
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