Springboot项目整合spring-kafka依赖包配置

有这种方式，就是可以是把之前test里的配置在这写上，用@Bean注解上。

现在来介绍第二种方式：

1.添加kafka依赖：

2.添加kafka配置方式:

编写代码发送消息：

测试：

我们要先能创建当前的topic：

Springboot项目整合spring-kafka监听消费消息

编写配置文件：

监听每秒消费一次：

Kafka事务消息-整合SpringBoot实战

写一段controller：

测试：

声明式事务写法：

这就是我们事务的使用。