1. 使用Flink的Checkpointing机制：Flink CDC内部使用Flink的Checkpointing机制来实现容错性。
通过在作业配置中启用Checkpointing，并设置适当的检查点间隔和持久化方式，Flink会周期性地生成检查点。可以使用Flink的REST API或命令行工具来查询最新的检查点。
2. 使用Flink的状态后端：Flink CDC使用Flink的状态后端来管理作业状态。可以配置状态后端将状态存储在可靠的持久化存储中，如文件系统或分布式数据库。通过查询状态后端，可以获取当前的检查点信息。
这两种方式可以帮助获取Flink CDC作业的当前检查点，从而实现容错和恢复的目的。
匿名回答于2023-09-23 09:14:46
