Playbooks

Handle late data for each consumer

Records arrive after the watermark: drop them (and count them), divert them, or re-fire the window as totals or as deltas? Three questions per consumer, decided by what a missing record costs it, how much state you can keep, and what its sink can absorb.