使用stream重构分布式事务项目启动异常

Question

视频中老师在配置文件中rocketmq增加bindings并指定producer的group为tx-add-bonus-group，本人和老师改动一致但是启动项目的时候出现异常，如下图所示：

当然RocketMQTransactionListener的txProducerGroup = “tx-add-bonus-group”

Answer 1

大目 2021-12-17 15:04:42

您好，请问您用的版本是？如果用的Spring Cloud Alibaba最新版本，那么事务消息稍有区别，配置不太一样：

https://github.com/alibaba/spring-cloud-alibaba/blob/master/spring-cloud-alibaba-docs/src/main/asciidoc-zh/rocketmq-new.adoc

详见这里，发送事务消息用producerType属性设置。

示例代码在这里：https://github.com/alibaba/spring-cloud-alibaba/blob/master/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-produce-example/src/main/resources/application.properties

相关配置是这仨：

spring.cloud.stream.rocketmq.bindings.output2.producer.producerType=Trans

spring.cloud.stream.rocketmq.bindings.output2.producer.group=myTxProducerGroup

spring.cloud.stream.rocketmq.bindings.output2.producer.transactionListener=myTransactionListener

----

如果不是最新版本，可以用我的代码试试哈（不过从您贴出来的代码来，代码是OK的，目前更倾向于怀疑版本上的问题）：

https://git.imooc.com/coding-358/content-center-12/src/master/src/main/resources/application.yml

• 提问者 夏洛爱的不是秋雅 #1

  感谢老师抽空回答，我使用的Spring Cloud Alibaba版本是您课上使用的0.9.0.RELEASE
  <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                  <version>0.9.0.RELEASE</version>
                  <type>pom</type>
                  <scope>import</scope>
              </dependency>

• 大目 #2

  您好，那可以对照我的代码看看哦