canal.mq.flatMessage = false

[jingdan]

你好，这个应该是canal配置导致写到kafka的格式有问题，可以联系下canal的同学看下