Skip to content

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

  1. Connect — attach to the source change log (Postgres WAL, MySQL binlog, MongoDB oplog, DynamoDB Streams, or Kafka topics). See CDC sources.
  2. Capture — tag each row with mutation kind, event ID, and a lexicographic order token; write to the WAL.
  3. Apply — upsert-if-newer with order-token guards; deletes use tombstones so stale writes cannot resurrect rows. See CDC destinations.
  4. Verify — target state converges on source state; resume from the stored checkpoint on restart.