1、消息体过大，当刷数据的时候消息体过大就会报错解决办法第一步修改canal服务端mq的配置canal.mq.maxRequestSize = 1048576 （默认为1m，根据需求修改）第二部修改队列的最大消息体大小/bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic test --config max.message.bytes=52428802、Deployer记录详细日志， 再instance日志可以查询到
大数据
2023-12-17
57 点赞
0 评论
86 浏览
