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

[Xuyang]

Hi, 请问你的需求是 “debezium数据”-> flink ->“canal ”么？ 
如果是这样的话，可以用UDF[1]来尝试下。<br/><br/>[1] 
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/udfs/
在 2022-08-21 10:49:29，"casel.chen" <casel_c...@126.com> 写道：
>flink cdc如何将捕获变更记录转成canal json格式输出到下游kafka?
>flink cdc获取的是debezium格式记录（用的是 JsonDebeziumDeserializationSchema)，要如何转换成canal 
>json格式输出呢？有没有例子或关键代码展示？谢谢！