[
https://issues.apache.org/jira/browse/FLINK-35693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-35693:
-------------------------------
Fix Version/s: (was: cdc-3.5.0)
> Change variable specificOffsetFile, specificOffsetPos and
> startupTimestampMillis to Offset in StartupOptions
> ------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-35693
> URL: https://issues.apache.org/jira/browse/FLINK-35693
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Affects Versions: cdc-3.1.1
> Reporter: Hongshun Wang
> Priority: Major
>
> Current, StartupOptions use specificOffsetFile, specificOffsetPos and
> startupTimestampMillis to describe specific offset or timestamp. However,
> it's suitable for mysql, rather than postgres's LSN or oracle's RedoLogOffset.
> {code:java}
> public final class StartupOptions implements Serializable {
> private static final long serialVersionUID = 1L;
> public final StartupMode startupMode;
> public final String specificOffsetFile;
> public final Integer specificOffsetPos;
> public final Long startupTimestampMillis;
> } {code}
> Now that we have already retract Offset to represent the position of log, why
> not use offset in StartupOptions?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
