#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