Change data capture
Capture every insert, update, and delete from supported source databases and apply them to your warehouse with order-token guards and tombstone anti-resurrect protection.
Full contract: CDC overview and CDC guarantees.
How it runs
- Connect — attach to the source change log (Postgres WAL, MySQL binlog, MongoDB oplog, DynamoDB Streams, or Kafka topics). See CDC sources.
- Capture — tag each row with mutation kind, event ID, and a lexicographic order token; write to the WAL.
- Apply — upsert-if-newer with order-token guards; deletes use tombstones so stale writes cannot resurrect rows. See CDC destinations.
- Verify — target state converges on source state; resume from the stored checkpoint on restart.
