开发者社区 问答 正文

canal1.1.5对接阿里云RocketMQ问题

canal.mq.flatMessage = false的情况下 报错Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 1 DESC: the topic[***] is batch send , not support. BROKER

阿里云rocketmq不支持批量发送

原提问者GitHub用户nikolabai

展开
收起
山海行 2023-04-27 16:53:35 151 分享 版权
1 条回答
写回答
取消 提交回答
  • 改下canal源码,发送消息的地方改为非批量,或者不使用json消息,客户端解析protobuf数据

    原回答者GitHub用户nikolabai

    2023-04-27 22:43:00
    赞同 展开评论