Windows单机配置Kafka环境
首先確保機器已經安裝好Zookeeper,Zookeeper安裝參考 Windows單機配置Zookeeper環境
然后確保Zookeeper是正常啟動狀態
下載Kafka
http://kafka.apache.org/downloads.html
下載二進制包下載后解壓縮,我這里解壓縮到了 D:\WorkSoftware\kafka_2.11_0.10.1.0 目錄
?
首先建立一個空文件夾 logs
建立logs文件夾進入config目錄,編輯 server.properties 文件
編輯server.properties修改 log.dirs 屬性部分的地址
?
然后在 D:\WorkSoftware\kafka_2.11_0.10.1.0 目錄,按住shift+鼠標右鍵
在此處打開命令窗口然后輸入下面命令
.\bin\windows\kafka-server-start.bat .\config\server.properties回車,執行命令
出現錯誤如果出現錯誤,我這里分析是CLASSPATH沒有配置正確,那么,先設置CLASSPATH,然后再執行
SET CLASSPATH=.; 設置CLASSPATH 成功測試一下,首先進入 D:\WorkSoftware\kafka_2.11-0.10.1.0\bin\windows 目錄,然后在當前目錄打開命令窗口
輸入下面命令,創建一個topic
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test.topic如果還遇到無法加載類等錯誤,還是先設置CLASSPATH
遇到無法加載主類,需要設置CLASSPATH topic創建成功打開一個Producer
kafka-console-producer.bat --broker-list localhost:9092 --topic test.topic 執行命令,打開生產者這三個窗口不關閉的情況下(zookeeper/kafka/producer),再次開啟一個命令窗口(還是在kafka目錄右鍵打開),輸入下面命令,開啟Consumer
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test.topic這樣,這里就有4個命令窗口
分別是
下面,我們在3號窗口(Producer)輸入一些字符,就會看到4號窗口馬上就收到消息
至此,Kafka的Windows單機環境搭建完畢
作者:sphsyv
鏈接:https://www.jianshu.com/p/64d25dcf8300
來源:簡書
簡書著作權歸作者所有,任何形式的轉載都請聯系作者獲得授權并注明出處。
轉載于:https://www.cnblogs.com/houxinxin/p/9188973.html
總結
以上是生活随笔為你收集整理的Windows单机配置Kafka环境的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: android四个组件的跨进程通信
- 下一篇: os模块:与操作系统交互的一个接口