开发者社区> 问答> 正文

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 126 0
1 条回答
写回答
取消 提交回答
  • 改下canal源码,发送消息的地方改为非批量,或者不使用json消息,客户端解析protobuf数据

    原回答者GitHub用户nikolabai

    2023-04-27 22:43:00
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
RocketMQ Client-GO 介绍 立即下载
RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载