Stateful Stream Processing Internals: Exactly-Once Semantics with Chandy-Lamport Snapshots
A comprehensive architectural guide to stateful distributed stream processing: mastering Event Time vs. Processing Time, Watermark heuristics for out-of-order data, RocksDB state backends, the Chandy-Lamport checkpoint barrier algorithm, and end-to-end Exactly-Once processing with 2PC sinks in Apache Flink and Kafka Streams.