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