StefanPapp
9/28/2018 - 5:14 PM

#Kafka Console Demo

#Kafka Console Demo

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

#in another window
telnet localhost 2181
stat

#start kafka
bin/kafka-server-start.sh config/server.properties
 
#create topic 
bin/kafka-topics.sh --create --topic chat --zookeeper localhost:2181 --replication-factor 1 --partitions 1

#verify
cd /tmp/kafka-logs/my_topic-0/
 
bin/kafka-topics.sh --list --zookeeper localhost:2181


kafka-console-producer.sh --broker-list localhost:9092 --topic chat

kafka-console-consumer.sh --bootstrap-server=localhost:9092 --consumer.config=config/consumer.properties --topic chatdemo --from-beginning
 
cat *.log in messages folder