Operating Streams: Backpressure and Replay
Lag, replay, and upgrades are where stateful streaming jobs usually fail. Work through the arithmetic and the procedures that keep restarts and rollouts safe.
-
-
Stateful Stream Processing and Checkpoint Recovery
A checkpoint restores a job’s state, not the outside world. Trace restart, sink commits, and crash points to see where exactly-once ends.
-
Event Time, Watermarks, and Late Data
A watermark is an estimate, not a fact. See how the delay you choose trades result latency against dropped or revised records, and what it costs in state.