应该是。通过源码可以知道flink-json目前支持2种内置json格式的解析，一个是canal，一个是debezium。
具体可参考： org.apache.flink.formats.json.canal.CanalJsonDeserializationSchema 和 org.apache.flink.formats.json.debezium.DebeziumJsonDeserializationSchema
在 2020/8/24 17:27, dixingxin...@163.com 写道:
Hi all： Flink1.11 的cdc是支持加载历史数据的，有两个问题想求证一下： 1.底层是使用了debezium来加载历史数据的吗？ 2.debezium是通过jdbc查询源表的数据来加载全量的历史数据吗？ 这块会不会对数据库造成瞬时压力？ 希望能帮忙解答一下，谢谢。 Best, Xingxing Di
