kafka处理超大消息的配置 org.apache.kafka.common.errors.RecordTooLargeException

在使用 canal 和kafka处理数据同步时canal日志提示如下异常: java.lang.RuntimeException: 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 原因是消息过大无法处理 第一步:修改 canal/conf/canal.properties配置