Springboot 2.x集成kafka 2.2.0的示例代码

目录

引言
基本环境
代码编写
1、基本引用pom
2、基本配置
3、实体类
4、生产者端
5、消费者
6、测试
效果展示
遇到的问题

引言

kafka近几年更新非常快，也可以看出kafka在企业中是用的频率越来越高，在springboot中集成kafka还是比较简单的，但是应该注意使用的版本和kafka中基本配置，这个地方需要信心，防止进入坑中。

版本对应地址：https://spring.io/projects/spring-kafka

基本环境

springboot版本2.1.4

kafka版本2.2.0

jdk>

代码编写

1、基本引用pom

<?xml>

2、基本配置

spring.kafka.bootstrap-servers=2.1.1.1:9092 spring.kafka.consumer.group-id=test-consumer-group spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer >

3、实体类

package>

4、生产者端

package>

5、消费者

package>

6、测试

在启动方法中模拟消息生产者，向kafka中发送消息

package>

效果展示

命令行直接消费消息

遇到的问题

生产端连接kafka超时

at>

解决方案：

修改kafka中的server.properties中的下面配置，将原来的默认配置替换成下面ip+端口的形式，重启kafka

到此这篇关于Springboot 2.x集成kafka 2.2.0的示例代码的文章就介绍到这了,更多相关Springboot集成kafka内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！