1. 程式人生 > >zookeeper與kafka 測試

zookeeper與kafka 測試

1.zookeeper安裝包下載:http://zookeeper.apache.org/releases.html#download

2.kafka安裝包下載:http://kafka.apache.org/downloads.html  

具體安裝細節見https://blog.csdn.net/evankaka/article/details/52421314

zookeeper測試:zkServer

kafka測試:

1.在kafka安裝路徑下新啟一個cmd視窗,執行.\bin\windows\kafka-server-start.bat .\config\server.properties

2.在kafka安裝路徑下新啟一個cmd視窗,建立topic "linlin":.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic linlin

3.在kafka安裝路徑下新啟一個cmd視窗,建立一個生產者:.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic linlin     不要關閉該視窗

4.在kafka安裝路徑下新啟一個cmd視窗,建立一個消費者:.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic linlin

5.生產者視窗輸入任意內容,消費者視窗可以同步顯示