bat kafka启动_windows下搭建Kafka,并通过命令窗口收发消息
參考網址:
前提條件:windows環境需要安裝jdk
2.由于Kafka依賴于zookeeper,所以也需要下載zookeeper,可以通過官網下載http://zookeeper.apache.org/
3.安裝zookeeper
將壓縮包解壓后,到bin目錄下,啟動zkServer.bat即可
注意:zookeeper的默認地址為:localhost:2181;需要配置環境變量:新建ZOOKEEPER_HOME,路徑為zookeeper安裝目錄,將%ZOOKEEPER_HOME%\conf添加到path中
啟動zookeeper成功
4.安裝Kafka
解壓kafka壓縮包,其中Kafka配置文件config\server.properties中zookeeper的地址也默認為localhost:2181
選中kafka解壓文件,shift+鼠標右鍵,選中“在此處打開命令行窗口(W)”,打開命令行,輸入以下命令啟動kafka:
bin\windows\kafka-server-start.bat config\server.properties
啟動完成后,再選中kafka解壓文件,shift+鼠標右鍵,選中“在此處打開命令行窗口(W)”,打開命令行,輸入以下命令,創建一個topic主題
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
使用如下命令查看創建的主題列表:bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
啟動生產者,可以發送消息:
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
執行上面命令之后,可以在控制臺隨意輸入文本
然后再選中kafka解壓文件,shift+鼠標右鍵,選中“在此處打開命令行窗口(W)”,打開命令行,輸入以下命令啟動消費者
bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning
可以看到能夠消費者成功接收消息
總結
以上是生活随笔為你收集整理的bat kafka启动_windows下搭建Kafka,并通过命令窗口收发消息的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: java单精度实型_Java的八种基本类
- 下一篇: java怎么获取该项目系统的参数_Jav