kafka使用步驟

2021-08-14 04:53:26 字數 889 閱讀 2763

1.    執行zookeeper:執行zookeeper\bin目錄下zkserver.cmd(不要關閉)

2.    執行kafka:在kafaka目錄下shift+右鍵進入命令框:

a.執行:.\bin\windows\kafka-topics.bat-list -zookeeper 127.0.0.1:2181

然後執行.\bin\windows\kafka-server-start.bat.\config\server.properties(不要關閉)

b.重新在kafka目錄下開啟命令列,執行建立主題**:.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181--replication-factor 1 --partitions 1 --topic lv再執行發訊息的命令:.\bin\windows\kafka-console-producer.bat --broker-list  localhost:9092 --topic lv(不要關閉)

c.重新在kafka目錄下開啟命令框:輸入接收訊息命令:.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181--topic lv(不要關閉)

d.發訊息前刪除kafka檔案目錄下project fileskafka資料夾

e.在發訊息的命令框裡面傳送字串,回車,如果接收訊息的命令框能拿到字串,表示能正常發收訊息(不要關閉)

3.    執行redis,windows 執行(快捷鍵:按住shift + 滑鼠右鍵),選擇在此處開啟命令視窗,進入cmd作業系統視窗。使用命令【.\redis-server.exeredis.windows.conf】,啟動redis 服務。(不要關閉)

Kafka安裝步驟

1.安裝包 kafka 2.11 1.1.0.tgz 2.把安裝包放在 data program 資料夾下,如果沒有program資料夾,則建立乙個 mkdir program 3.解壓 tar zxvf kafka 2.11 1.1.0.tgz 4.修改 config server.propeti...

kafka集群搭建步驟

1 搭建軟體環境 1 linux一台或多台,大於等於2 2 已經搭建好的zookeeper集群 2 解壓tar zxvf kafka 2.10 0.10.1.1.tgz 3 在kafka安裝目錄下,新建目錄kafkalogs 4 在config目錄下修改配置檔案server.properties,b...

kafka阻塞排錯步驟

1.首先獲取所有的topic的列表 bin kafka topics.sh list zookeeper localhost 2181 2.檢視某乙個topic下的log檔案和offset是不是一樣 下一單之後再次檢視有沒有變化,應該是log檔案和offset同時加1才對,如果不是同時加1說明阻塞 ...