nisham22
3/7/2018 - 5:50 AM

Kafka

Download Kafka

wget http://www-eu.apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.tgz

Zookeeper Start

bin/zookeeper-server-start.sh config/zookeeper.properties

Kafka Start

bin/kafka-server-start.sh config/server.properties

Topic Creation

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topicName

List all Topics

bin/kafka-topics.sh --list --zookeeper localhost:2181

Delete Topic

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic topicName

Producer Start

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topicName

Consumer Start

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning