Search before asking

• I searched in the issues and found nothing similar.

Flink version

1.18

Flink CDC version

3.0

Database and its version

anyway

Minimal reproduce step

Reason

Current, read snapshot split then backfill between [low_watermark, high_watermark], then read in stream phase between [high_watermark, +∞). The message of high_watermark will be read twice.

What did you see instead?

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!