Skip to main content
A source reads data in one of three modes, declared as ReplicationMode in its ConnectorSpec: A connector advertises which modes it supports through ConnectorSpec.Modes — not every source implements all three. Incremental and CDC extraction build on the same checkpointing machinery described in Integrity & checkpoints.
PostgreSQL is a good example of a source that picks its read strategy dynamically even within a single mode — see Postgres source for how it chooses between keyset, bitmap, and ctid-based scans.