Mrart commented on PR #3950:
URL: https://github.com/apache/flink-cdc/pull/3950#issuecomment-2807954731
@ruanhang1993 @phamvinh1712
Based on your description of PostgreSQL's LSN (Log Sequence Number) and its
similarity to Kafka's offset management, here is the translated version of your
proposed scan.startup.mode for PostgreSQL:
Proposed scan.startup.mode for PostgreSQL:
initial: Full and incremental synchronization integrated as one.
committed-offset: Start synchronization from the confirmed_flush_lsn.
latest-offset: Start synchronization from the latest LSN.
earliest-offset: Start synchronization from the earliest LSN in the WAL
log.
specific-offsets: Create a replication slot starting from a
user-specified LSN.
This structure aligns with Kafka's offset management while adapting it to
PostgreSQL's replication mechanisms, such as the use of restart_lsn,
confirmed_flush_lsn, and WAL logs. It provides clear options for defining the
starting point of data synchronization in a logical replication setup.
refrence:
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/kafka/#start-reading-position
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
