[Optimization][MySQLCDC] MySQLCDCBuild can't support earliest-offset
or timestamp
scanStartupMode now.Hope to upgrade it.
#3090
Labels
Optimization
Optimization function
Search before asking
Description
situation:It seems like MySQLCDCBuild do not support
earliest-offset
andtimestamp
scanStartupMode. Perhaps you can upgrade the version of cdc version to be more useful in production.if (Asserts.isNotNullString(config.getStartupMode())) { switch (config.getStartupMode().toLowerCase()) { case "initial": sourceBuilder.startupOptions(StartupOptions.initial()); break; case "latest-offset": sourceBuilder.startupOptions(StartupOptions.latest()); break; default: } } else { sourceBuilder.startupOptions(StartupOptions.latest()); }
version: dlink-0.7.0/ flink-1.14
Are you willing to submit a PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: