ticdc同步到kafka配置问题

使用的协议是 maxwell,该协议会对多个事件做 batch 操作。从源代码上看,max-batch-size 在该协议上是不生效的。maxwell 不是 TiCDC 官方 GA 的协议。

从给出的配置来看,max-message-bytes 给的值是 262144,即 256k。如果一次性 batch 的消息大小操过该值,就会发生 message too large 的做错。

即然你的下游 kafka 给的消息大小限制是 4MB,你完全可以不用管该参数啊,或者也给个 4MB 即可。