本地zookeeper的啟動,kafka的啟動

2021-10-01 23:25:10 字數 1329 閱讀 7136

建議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...