Apache Flink: Reading and Modifying Kafka Consumer Offsets Using the State Processor API

A practical guide to inspecting and rewriting Kafka partition offsets inside Flink savepoints using the State Processor API, including the undocumented coordinator state serialization format.