java Kafka 簡單應用實例


kafka官方中文文檔  http://kafka.apachecn.org/
java Kafka 簡單應用實例  下面是Linux下的單機模式:https://blog.csdn.net/fct2001140269/article/details/83246770
Kafka在Windows安裝運行及入門實例(JAVA)https://blog.csdn.net/shiyuezhong/article/details/79897719
ZooKeeper下載安裝(Windows版本) https://blog.csdn.net/ring300/article/details/80446918
 
在Windows安裝運行Kafka https://blog.csdn.net/weixin_38004638/article/details/91893910

 1.創建主題,進入Kafka安裝目錄D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右鍵,選擇“打開命令窗口”選項,打開命令行,輸入:

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

2.查看主題輸入
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
3. 創建生產者,進入Kafka安裝目錄D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右鍵,選擇“打開命令窗口”選項,打開命令行,輸入:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
注意:不要關了這個窗口
4. 創建消費者,進入Kafka安裝目錄D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右鍵,選擇“打開命令窗口”選項,打開命令行,輸入:
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
 
時,往生產者窗口寫入消息,消費者窗口也能同步的接收到消息
 
啟動kafka
.\bin\windows\kafka-server-start.bat .\config\server.properties


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM