stream:
      rocketmq:
        binder:
          name-server: 129.211.164.53:9876
        bindings:
          output:
            producer:
              transactional: true
              group: tx-user-coupon-group
      bindings:
        output:
            #用来指定Topic
          destination: coupon-infoss
        my_output:
          destination: my-infos

maven 配置

<dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
 </dependency>

这么处理之后 一般信息就无法发送到 MQ 控制台，也不报错 尴尬。急急急

请求结果

"error": "Internal Server Error",
    "message": "failed to send Message to channel 'output'; nested exception is java.lang.IllegalStateException: Failed to convert message: 'GenericMessage [payload=UserCouPonDto.UserCouPonDtoBuilder(userId=1, type=3), headers={id=071e57d0-03e2-d444-a28d-4181f17bd1dc, TRANSACTION_ID=752b842e-5974-467e-8553-e2ec6bc19fc3, contentType=application/json, dto={\"id\":1,\"sex\":3}, timestamp=1584525219256}]' to outbound message.",
    "path": "/user/update"