kafka近几年更新非常快，也可以看出kafka在企业中是用的频率越来越高，在springboot中集成kafka还是比较简单的，但是应该注意使用的版本和kafka中基本配置，这个地方需要信心，防止进入坑中。
版本对应地址：https://spring.io/projects/spring-kafka
基本环境springboot版本2.1.4
kafka版本2.2.0
jdk 1.8
代码编写 1、基本引用pom 2、基本配置 3、实体类 4、生产者端 5、消费者 6、测试在启动方法中模拟消息生产者，向kafka中发送消息
效果展示命令行直接消费消息
遇到的问题生产端连接kafka超时
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:119)
解决方案：
修改kafka中的server.properties中的下面配置，将原来的默认配置替换成下面ip+端口的形式，重启kafka
到此这篇关于Springboot 2.x集成kafka 2.2.0的示例代码的文章就介绍到这了,更多相关Springboot集成kafka内容请搜索七叶笔记以前的文章或继续浏览下面的相关文章希望大家以后多多支持七叶笔记！
