statrer引入
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.3</version>
</dependency>
starter 2.0.2对应rocketmq 4.4.0
starter 2.1.0对应rocketmq 4.6.0
4.X版本的mq还有一年多停止支持,尽快升级到5.X的版本吧。
从starter 2.1.0开始, rocketMQTemplate.sendMessageInTransaction()的第一个参数txProducerGroup就移除了。
那么如果一个项目中需要执行多个mq事务该怎么做呢,靠以前的定义多个txProducerGroup不管用了,官网文档给出了解决方案,那就是定义多个extra RocketMQTemplate
文档地址:https://github.com/apache/rocketmq-spring/wiki/FAQ
相关章节如下
定义一个extra RocketMQTemplate
使用extra RocketMQTemplate发送事务消息
为何移除,参见https://github.com/apache/rocketmq-spring/pull/179