[FLINK-35693] Change variable specificOffsetFile, specificOffsetPos and startupTimestampMillis to Offset in StartupOptions

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: cdc-3.1.1
• Fix Version/s: cdc-3.3.0
• Component/s: Flink CDC
• Assignee: Unassigned
• Reporter: Hongshun Wang
• Created: 25/Jun/24 08:48
• Updated: 05/Sep/24 07:05

Description

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.

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;
} 

Now that we have already retract Offset to represent the position of log, why not use offset in StartupOptions?