1.安裝前準備

jdk1.8.0_171
kafka_2.10-0.10.0.0.tgz
將壓縮包解壓至kafka使用者目錄.

2.配置檔案

• config/server.properties

#修改一下幾項,其他不動
#唯一標識，叢集內各個broker.id不能重複
broker.id=0 

#埠號
port=9092

#日誌檔案目錄
log.dirs =/home/kafka/logs

#zk連線地址
zookeeper.connect=192.168.163.101:2181,192.168.163.102:2181,192.168.163.103:2181

#是否真實刪除主題.預設false
delete.topic.enable=true 
 

修改完成後傳送至各個節點.

3.啟動

nohup bin/kafka-server-start.sh config/server.properties &

4.簡單測試

• 建立主題

#replication-factor指的是資料檔案副本數
bin/kafka-topics.sh --create --zookeeper 192.168.163.101:2181 --replication-factor 2 --partitions 1 --topic test

• 列出所有主題

bin/kafka-topics.sh --list --zookeeper 192.168.163.101:2181
 

• 啟動生產任務(自帶指令碼)

bin/kafka-console-producer.sh --broker-list 192.168.163.101:9092,192.168.163.102:9092,192.168.163.103:9092 --topic test

• 啟動消費任務(自帶指令碼)

bin/kafka-console-consumer.sh --zookeeper 192.168.163.101:2181 --topic test

在生產端輸入訊息後,會在消費端打印出來.