Flink CDC 2.0 支持全量故障恢复，可以从 checkpoint 点恢复。
在 Flink CDC 2.0 中，每个 source 都会有一个对应的 changelog topic，用于记录该 source 的所有变更信息。当发生故障时，Flink CDC 2.0 会从最近的 checkpoint 点开始消费 changelog topic 中的消息，将数据恢复到故障前的状态。
具体来说，Flink CDC 2.0 的全量故障恢复过程如下：
Flink CDC 2.0 会在每个 source 上启动一个 ChangelogReaderThread，用于读取该 source 的 changelog topic。
当发生故障时，Flink CDC 2.0 会从最近的 checkpoint 点开始消费 changelog topic 中的消息。
ChangelogReaderThread 会将消费到的消息发送给对应的 source task，以更新其内部的状态。
Flink CDC 2.0 会等待所有 source task 都完成状态更新后，才会认为全量故障恢复完成。
需要注意的是，Flink CDC 2.0 的全量故障恢复需要保证 changelog topic 中的消息是有序的。如果消息无序，可能会导致数据丢失或者重复处理。因此，在使用 Flink CDC 2.0 时，需要确保 changelog topic 中的消息是有序的。
Flink本身提供了Json解析器，可以将Json数据解析到表结构中。但是，对于复杂的Json数据，可能需要自定义解析逻辑或者使用第三方插件来解析。
目前比较常用的Json解析插件有：
json-simple：一个轻量级的Json解析库，可以方便地将Json数据转换为Java对象。
Jackson：一个流行的Json解析库，支持将Json数据转换为Java对象、XML和CSV等格式。
Gson：一个由Google开发的Json解析库，可以将Json数据转换为Java对象和POJO类。
这些插件都可以通过Flink的Table API或者SQL API来使用。具体使用方法可以参考官方文档或者相关教程。
