flink cdc如何将捕获变更记录转成canal json格式输出到下游kafka?

flink cdc如何将捕获变更记录转成canal json格式输出到下游kafka?
flink cdc获取的是debezium格式记录（用的是 JsonDebeziumDeserializationSchema)，要如何转换成canal 
json格式输出呢？有没有例子或关键代码展示？谢谢！

回复