A cursor is useful only while its source history remains available. Define source ordering, stable event identity and sink-version rules so duplicates and delayed updates converge to the correct state.
In this chapter
- Watermarks, CDC, MERGE, and idempotencyKeep incremental data accurate despite duplicates, late events, updates and retries.
For a full recovery procedure, see resumable pipelines, replay and backfills.