forachange
forachange
也存在类似问题。 后来调整了 canal.properties 里的 kafka.max.request.size，以及 kafka broker 端 topic 的 max.message.size ``` bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name my-topic --alter --add-config max.message.bytes=128000 ``` (参考 https://kafka.apache.org/21/documentation.html#topicconfigs) 目前运行运行正常
mark, 看看怎么解决
同问，该怎么解决呢？
4.3.2，新版本目前使用可以