Project Every Record Counts: Data Engineering for Backend Engineers
Part 29: "Stateful Streams in Java" — Apache Flink II
Rohan writes the stock-out detector like a Spring service, and a restart pages stores twice. Keyed state, event-time timers, side outputs, checkpoints and savepoints, exactly-once sinks, upgrades and backpressure in Flink's Java DataStream API, proven by killing a TaskManager mid-run.