SpringBoot與Kafka集成


springboot集成kafka

本項目是基於Windows環境開發的。

環境要求:

1.JDK環境。

2.zookeeper環境。

3.kafka安裝。

以上3步百度都有安裝教程。

4.kafka問題

a:kafka啟動失敗,提示jdk環境不存在。

解決:kafka-run-class.bat 179 行中%CLASSPATH%為"%CLASSPATH%"(添加雙引號即可)。

b:kafka-console-consumer.bat --zookeeper localhost:2181 --topic test啟動消費者失敗。

解決:因為kafka版本問題,不在支持這個命令,修改命令為

.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning 即可。

 

代碼已經上傳到碼雲

碼雲鏈接:https://gitee.com/xxxcxy/springboot-kafka

 


免責聲明!

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



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