Flink CDC2.0 StartupOptions作用

说明

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