赞
踩
Springboot项目整合spring-kafka依赖包配置
有这种方式,就是可以是把之前test里的配置在这写上,用@Bean注解上。
现在来介绍第二种方式:
1.添加kafka依赖:
2.添加kafka配置方式:
编写代码发送消息:
测试:
我们要先能创建当前的topic:
Springboot项目整合spring-kafka监听消费消息
编写配置文件:
监听每秒消费一次:
Kafka事务消息-整合SpringBoot实战
写一段controller:
测试:
声明式事务写法:
这就是我们事务的使用。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。