已解决 canal同步kafka提示The request included a message larger than the max message size the server will accept.

[yixi]

canal动态添加主题，报错如下：

Caused by: org.apache.kafka.common.errors.RecordTooLargeException: The request included a message larger than the max message size the server will accept.
2021-02-23 16:19:46.899 [pool-32-thread-5] ERROR com.alibaba.otter.canal.kafka.CanalKafkaProducer - java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.RecordTooLargeException: The request included a message larger than the max message size the server will accept.

[CloudCanal-万少]

这个报错是你消息体过大了，可以尝试下如下的方式：

1. 修改 canal/conf/canal.properties配置，调整更大的值

canal.mq.maxRequestSize = 10485760

2. 修改kafka/config/producer.properties ，调整更大的值

max.request.size=12695150

3. 修改kafka/config/server.properties ，调整更大的值

message.max.bytes=12695150

4. 重启服务