End-to-End Exactly-Once Processing in Apache Flink with Apache Kafka
How Apache Flink combines checkpoints with a two-phase commit protocol to deliver end-to-end exactly-once semantics with Apache Kafka transactions.
Piotr Nowojski9 min read
How Apache Flink combines checkpoints with a two-phase commit protocol to deliver end-to-end exactly-once semantics with Apache Kafka transactions.
MediaMath rescaled its stateful Flink reporting job after the 2017 S3 outage. A deep dive into how Flink redistributes operator state and keyed state with key groups.