dgadiraju
12/11/2017 - 12:19 AM

kakfademodg.sh

kafka-topics.sh --create \
   --zookeeper nn01.itversity.com:2181,nn02.itversity.com:2181,rm01.itversity.com:2181 \
   --replication-factor 1 \
   --partitions 1 \
   --topic kafkademodg

kafka-topics.sh --list \
   --zookeeper nn01.itversity.com:2181,nn02.itversity.com:2181,rm01.itversity.com:2181 \
   --topic kafkademodg

kafka-console-producer.sh \
  --broker-list nn01.itversity.com:6667,nn02.itversity.com:6667,rm01.itversity.com:6667 \
  --topic kafkademodg

kafka-console-consumer.sh \
  --zookeeper nn01.itversity.com:2181,nn02.itversity.com:2181,rm01.itversity.com:2181 \
  --topic kafkademodg \
  --from-beginning