一、JDK安裝
二、ZK安裝
三、kafka安裝
kafka是基於jdk和zk上運行的,安裝kafka前必須安裝jdk和zk。
-
Kafka下載路徑 http://kafka.apache.org/downloads
-
解壓文件(我的目錄是E:\software\kafka_2.12-2.3.0 【這里不要在Program Files等文件名之間有空格的目錄下,不然一會執行會不識別路徑】)
-
打開目錄E:\software\kafka_2.12-2.3.0\config下server.properties文件,把log.dirs修改為【log.dirs=E:\software\kafka_2.12-2.3.0\kafka-logs】,也可以直接在
-
進入kafka文件目錄D:\kafka_2.12-0.11.0.0,執行以下命令,啟動kafka通訊的服務器broker
.\bin\windows\kafka-server-start.bat .\config\server.properties
-
進入kafka文件目錄\bin\windows,創建kafka的消息topics
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testDemo
- 分別打開兩個cmd窗口,進入目錄D:\kafka_2.12-0.11.0.0\bin\windows,創建Producer和Consumer
(1)Producer
進入目錄D:\kafka_2.12-0.11.0.0\bin\windows輸入如下命令
kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo
(2)Consumer
進入目錄D:\kafka_2.12-0.11.0.0\bin\windows輸入如下命令
老版本命令
kafka-console-consumer.bat --zookeeper localhost:2181 --topic testDemo
如果上述命令報錯:zookeeper is not a recognized option,z這是因為新版本刪除直接綁定zk的命令,這運行新命令,綁定kafka服務
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testDemo
四、可視化工具 kafka Tool
下載地址http://www.kafkatool.com/download.html
安裝后進入配置
用工具就可以監控kafka的各種信息了,nice
參考