上一篇介紹了kafka的特點，這篇來記錄kafka的主要工作方式： 1.建立Topic， 2. 生產者生產  3.消費者消費

首先 建立 一個 test topic， 命令如下：

./kafka-topics.sh --zookeeper 172.28.201.217:2181 --create --topic test --replication-factor 2 --partitions 3

這裡有兩個引數需要注意：

replication-factor： 副本因子， 說明topic的每個分割槽分別有兩個副本

partitions： 分割槽數， 說明 該topic有三個分割槽

然後 生產者， 利用 命令列來向topic中生產資料:

./kafka-console-producer.sh --broker-list 172.28.201.211:9092,172.28.201.212:9092,172.28.201.213:9092 --topic test --producer.config ../config/producer.properties

 輸入資料

然後 消費者， 利用 命令列來消費topic中資料:

bin/kafka-console-consumer.sh --zookeeper 130.23.23.95:2181 --topic test --from-beginnin
 

結果如下

除此外 除錯常用的命令列還有

檢視 叢集裡的topic詳情
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --describe

只是列出所有主題名字
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --list

給叢集中test主題增加分割槽數到16
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --alert --topic test --partitions 16

刪除某個主題
./bin/kafka-topics.sh --zookeeper 10.95.26.27:2181 --delete --topic test