开发者社区> 问答> 正文

Canal投递MQ能否控制字段

canal版本: v1.1.3 MQ: RocketMQ 4.2 新闻表的内容字段没有投递到MQ,能否控制该字段不进行投递,否则会导致报错

org.apache.rocketmq.client.exception.MQClientException: CODE: 13 DESC: the message body size over max value, MAX: 4194304

PS: canal.mq.retries 配置为1,但还是会失败一直投递,导致卡住

原提问者GitHub用户cjk87927

展开
收起
数据大拿 2023-05-04 18:16:59 86 0
1 条回答
写回答
取消 提交回答
  • 发送的MQ消息超过了body限制,4194304

    可以考虑:

    调大MQ的body大小限制 调小canal发送MQ的批次大小,如果单条binlog记录都超过body限制,那就没招了

    原回答者GitHub用户agapple

    2023-05-05 10:46:52
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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