offset management

How Apache Flink manages Kafka consumer offsets

Step by step: how the Flink Kafka source stores partition offsets in checkpoints, how barriers keep operator state consistent, and how offsets are restored after a failure.