kafka

topic

create

bin/kafka-topics.sh --create --topic tweet --bootstrap-server winubuntu:9092, namubuntu:9092 --partitions 2 --replication-factor 2

list

bin/kafka-topics.sh --list --bootstrap-server winubuntu:9092, namubuntu:9092

delete

bin/kafka-topics.sh --delete --bootstrap-server winubuntu:9092, namubuntu:9092

Producer-Consumer

Producer console

bin/kafka-console-producer.sh --broker-list winubuntu:9092,namubuntu:9092 --topic tweet

Consumer

bin/kafka-console-consumer.sh --bootstrap-server winubuntu:9092,namubuntu:9092 --topic tweet