kafka的命令列操作
阿新 • • 發佈:2018-12-27
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