注：kafka依賴于zookeeper，官網(wǎng)下載的kafka內(nèi)置了zookeeper依賴。

1. 下載Kafka，網(wǎng)址：http://kafka.apache.org/

解壓縮：

2. 修改配置文件

進(jìn)入到config目錄，修改service.properties：

3. 進(jìn)行單機(jī)實(shí)例測試簡單使用

(1) 啟動kafka內(nèi)置的zookeeper

運(yùn)行cmd命令：
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

啟動kafka內(nèi)置zookeeper

不關(guān)閉當(dāng)前窗口。

(2) 啟動kafka服務(wù)

運(yùn)行cmd命令：
.\bin\windows\kafka-server-start.bat .\config\server.properties

啟動kafka服務(wù)

不關(guān)閉當(dāng)前窗口。

(3) 創(chuàng)建一個名為test1的topic測試主題kafka

運(yùn)行cmd命令：
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

創(chuàng)建kafka測試主題test1

該窗口可關(guān)閉。

(4) 創(chuàng)建消息生產(chǎn)者生產(chǎn)消息

運(yùn)行cmd命令：
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test1

創(chuàng)建消息生產(chǎn)者

不關(guān)閉當(dāng)前窗口。

(5) 創(chuàng)建消息消費(fèi)者接收消息

運(yùn)行cmd命令：
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test1 --from-beginning

創(chuàng)建消息消費(fèi)者

不關(guān)閉當(dāng)前窗口。

(6) 測試消息發(fā)送和接收

測試

測試成功。