建議kafka使用視覺化工具:
安裝bin目錄下:
zkserver.cmd
windows\kafka-server-start.bat ..\config\server.properties
之後進入到kafka的目錄下執行下面的命令,可以使用在資料夾的空白處按著shift加滑鼠右鍵開啟命令視窗
windows\kafka-server-start.bat ..\config\server.properties
!每次執行kafka的時候都要把這個和上面的zkserver開啟
之後可以測試一下建立乙個主題
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic hello
之後開啟生產者,進入到bin/windows目錄下使用命令視窗
.\kafka-console-producer.bat --broker-list localhost:9092 --topic test
.\kafka-console-producer.bat --broker-list localhost:9092 --topic hello
開啟消費者,進入到bin/windows目錄下使用命令視窗
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
.\kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic test --from-beginning
之後可以在生產者那個視窗隨意輸入一些資訊,之後就能在消費者那邊看到輸入的資訊
d:\software\kafka\kafka-2.3.0-src\bin\windows>kafka-topics.bat --zookeeper localhost:2181 --describe --topic tests
d:\software\kafka\kafka-2.3.0-src\bin\windows>kafka-topics.bat --bootstrap-server localhost:2181 --describe --topic tests
topic:tests partitioncount:1 replicationfactor:1 configs:
topic: tests partition: 0 leader: 0 replicas: 0 isr: 0
Zookeeper的安裝(本地)
這是他的官網,download 我現在的是3.4.10.tar.gz 上傳至伺服器或者虛擬機器,這裡提供乙個命令,知道請忽略 首先 執行這個命令 yum y install lrzsz 之後 直接輸入rz 選擇要上傳的檔案,就能把檔案上傳至伺服器或虛擬機器。解壓 tar zxvf zookeeper...
zookeeper啟動異常
zookeeper啟動異常 1.新部署的zookeeper或清理過資料資訊後,啟動zookeeper的時候報錯並啟動失敗。此時可能是以下幾個方面引起的 建立完以上兩個檔案後可以重試重啟。2.載入資料出錯 zk在啟動的過程中,首先會根據事務日誌中的事務日誌記錄,從本地磁碟載入最後一次提交時候的快照資料...
zookeeper本地模式安裝
解壓 tar zxvf zookeeper 3.4.10.tar.gz c opt module 配置修改 1 將 opt module zookeeper 3.4.10 conf 這個路徑下的 zoo sample.cfg 修改為 zoo.cfg mv zoo sample.cfg zoo.cfg...