Best pattern for handling late-arriving CDC events in a multi-table Delta pipeline?
We ingest change events from several operational systems, and a small percentage arrive hours after the normal watermark. The pipeline needs to keep customer and order tables consistent without replaying an entire day. How are teams combining watermarks, MERGE logic, and idempotency when related events arrive out of order? I am especially interested in patterns that stay understandable during incident response.
0