一 kafka安裝啟動

1.下載最新版kafka 
    Apache官網: http://kafka.apache.org/downloads.html
2.解壓kafka
    tar -zxvf kafka_2.12-1.0.0.tgz
3.重新命名解壓目錄名  
    mv kafka_2.12-1.0.0 kafka
4.啟動
    進入解壓目錄：cd kafka
    修改config/zookeeper.properties的日誌路徑
    啟動zookeeper：bin/zookeeper-server-start.sh config/zookeeper.properties
 
 &
    修改config/server.properties的日誌路徑
    啟動kafka：bin/kafka-server-start.sh config/server.properties &
5.停止
    停止kafka： bin/kafka-server-stop.sh
    停止zookeeper： bin/zookeeper-server-stop.sh

二 kafka的相關命令

// 建立topic （replication-factor：節點數）
sh bin/kafka-topics.sh --
 
create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic myTopic1
// 檢視佇列分割槽明細
sh bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic myTopic1
// 消費訊息 
sh bin/kafka-console-consumer.sh  --zookeeper localhost:2181  --from-beginning --topic loginfoTopic
// 檢視佇列列表
 

sh bin/kafka-topics.sh --list --zookeeper localhost:2181
// 刪除toppic
.bin/kafka-topics.sh  --delete --zookeeper localhost:2181  --topic test
// 修改分割槽數，注意只能往大的改
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic myTopic1 --partitions 4
//測試：啟動producer傳送訊息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic myTopic1
//測試：啟動consumer傳送訊息
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic myTopic1 --from-beginning