1. 建立topic
      # 注意：一般在系統設計的時候，先把topic規劃好，業務含義相同的資料，放在一個topic中。
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --create   --topic topica --partitions 3 --replication-factor 2

## ---------------引數說明------------------ ##
--zookeeper 連線的zookeeper
--create 表示要建立一個topic
--topic 指定topic的名字(不同業務的資料，放在不同的topic中)
--partitions 指定分割槽數
--replication-factor 指定副本數

2. 檢視所有topic
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --list

3. 檢視某個topic詳情
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --describe --topic topica
 

4. 刪除topic
[root@kafka1 kafka]# bin/kafka-topics.sh  --zookeeper kafka1:2181  --delete   --topic topica

5. 接收訊息
[root@kafka1 kafka]# bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092 --topic topica

6. 傳送訊息
[root@kafka1 kafka]# bin/kafka-console-producer.sh --broker-list      kafka1:9092 --topic topica