0. 前言
本說明使用國網中心(nchc) 台灣杉(taiwania) 資源服務
1.安裝方式
wget http://apache.stu.edu.tw/kafka/1.1.0/kafka_2.11-1.1.0.tgz
tar -xzf kafka_2.11-1.1.0.tgz
mv kafka_2.11-1.1.0 kafka/1
cd kafka
此軟體不需要root權限，解壓縮檔案之後，執行程式與其搭配的設定檔，即可常駐一個專門在處理streaming queue的agent service。
2. 啟動服務
- 啟動 zookeeper server
kafka 使用zookeeper 來同步訊息，因此要先啟動 zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
- 啟動 kafka server
接下來啟動 kafka server
bin/kafka-server-start.sh config/server.properties
以上設定檔使用預設的即可。
- 啟動 topic ( start a consumer )
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
如此就新增了一個 kafka topic
- 傳送訊息 (start a producer )
用以下指令來送出訊息到 topic名為 test 的queue
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
- 接收訊息 (start a consumer )
用以下指令來將 topic名為 test 的queue 接收訊息下來
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
4. 資源連結
- 官方說明資源