1）檢視當前叢集中已存在的主題topic

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

2)建立topic

bin/kafka-topics.sh --zookeeper master:2181 --create --replication-facto
r 3 --partitions 1 --topic guanxuan 

–zookeeper 連線zk叢集
–create 建立
–replication-factor 副本
–partitions 分割槽
–topic 主題名

3）刪除主題

bin/kafka-topics.sh --zookeeper master:2181 --delete --topic guanxuan 
 

4）傳送訊息

生產者啟動：
bin/kafka-console-producer.sh --blocker-list master:9092 --topic guanxuan --from-beginning
消費者啟動： 
 bin/kafka-console-consumer.sh --bootstrap-server master:9092 --topi

c guanxuan --from-beginning

5）檢視主題詳細資訊

bin/kafka-topics.sh --zookeeper master:2181 --describe --topic guanxuan