How to install Kafka


wget ""

tar -xzf kafka_2.11-1.1.0.tgz

Starting Zookeeper and kafka

bin/ config/
bin/ config/

Create topic

bin/ --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

List topics

bin/ --list --bootstrap-server localhost:9092


bin/ --list --zookeeper localhost:2181

Send some messages to Kafka

bin/ --broker-list localhost:9092 --topic test


bin/ --zookeeper localhost:2181 --topic test

Consume messages from Kafka

bin/ --bootstrap-server localhost:9092 --topic test --from-beginning

Leave a Reply

Your email address will not be published. Required fields are marked *