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