Flink CDC2.0 StartupOptions作用 作者：马育民 • 2022-06-18 19:58 • 阅读：11172 # 说明 `StartupOptions` 类的作用是指定监控的方式，有以下几种 # StartupOptions.initial() 通过注释可以明白，这是有两步操作结合的， 1. 先扫描下监控的这张表 2. 扫描完以后，立刻切换到最新的binlog，也就是最新的数据那里去。 比canel优越，canel只能监控最新的数据。 # StartupOptions.earliest() 从最早的数据开始读取，但是这样数据量太大了。 ### 应用场景 万一mysql删库了，可以用来恢复数据。 # StartupOptions.latest() 从最新的数据开始读取 # StartupOptions.specificOffset() ``` StartupOptions specificOffset(String specificOffsetFile, int specificOffsetPos) ``` 指定一个读取的文件信息，自己指定个任意个位置 使用比较少 # StartupOptions.timestamp() ``` StartupOptions.timestamp(long startupTimestampMillis) ``` binlog日志有时间戳，此方法是指定时间戳，从特定的时间来读取数据。 参考： https://blog.csdn.net/qq_39437513/article/details/119013648 原文出处：/show_1IX3WMCdbfZ6.html