準(zhǔn)備工作
- Java環(huán)境
- Kafka安裝包（已包含zookeeper）
安裝步驟
1 Java安裝
自行百度
2 下載友驮、安裝Kafka
打開 下載地址
-
選擇下圖紅框中的版本粪糙，Kafka包名組成： Scala版本 - Kafka自身版本
下載頁 -
下載完成之后解壓艰赞，目錄如下圖：
3 啟動(dòng)服務(wù)
3.1 啟動(dòng)ZooKeeper
打開kafka_2.12-2.1.0\bin\windows目錄变隔，該目錄下是所有windows命令：
在此目錄下打開cmd右遭，執(zhí)行命令zookeeper-server-start.bat ..\..\config\zookeeper.properties懈叹，如下圖：
3.2 啟動(dòng)Kafka
依舊在目錄下打開cmd乖杠，執(zhí)行命令kafka-server-start.bat ..\..\config\server.properties，如下圖：
OK项阴，啟動(dòng)成功滑黔。
注意：
如果出現(xiàn)‘命令語法不正確’ ，導(dǎo)致不能正常運(yùn)行环揽，嘗試修改配置文件的dataDir（zookeeper.properties）略荡，log.dirs（server.properties）。因?yàn)槟J(rèn)的是linux的文件目錄格式歉胶。
4 測試Kafka命令
- 創(chuàng)建一個(gè)主題
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic - 查看創(chuàng)建的主題列表
kafka-topics.bat --list --zookeeper localhost:2181
執(zhí)行完上面兩條命令后如下圖：
-
啟動(dòng)生產(chǎn)者：
kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic
此時(shí)可以從控制臺(tái)輸入信息汛兜，待消費(fèi)者啟動(dòng)后可接收到生產(chǎn)者發(fā)布的消息。
-
啟動(dòng)消費(fèi)者：
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning
此時(shí)便能看到發(fā)布出去的消息了
