1.kafka安裝包下載

在Apache的kafka官網下載安裝包，以下4個包隨便選一個下載。

2.啟動zookeeper的服務

進入檔案的解壓目錄，輸入

bin/zookeeper-server-start.sh config/zookeeper.properties

3.啟動kafka的服務

另起一個視窗,進入解壓目錄，輸入

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

4.配置topic

另起視窗，進入解壓目錄，輸入

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my_test
 

我們也可以通過以下命令檢視topic

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

到這裡topic就建立完成了

5.建立生產者

輸入以下命令可成功建立生產者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my_test

6.建立消費者

另起視窗，輸入以下命令：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_test --from-beginning
 

這樣消費者也建立成功了
我們可以在生產者的視窗中輸入一個1，可以發現消費者中也會出現一個1

到這裡，單點的kafka環境部署就全部結束了！