I wrote a new tutorial: Apache Flink: Reading and Modifying Kafka Consumer Offsets Using the State Processor API • Tutorial: https://streamacademy.io/tutorial/flink-kafka-consumer-offsets-with-the-state-processor-api/ • Full source code: https://github.com/irontools/flink-tutorials/tree/main/kafka-offsets

This is interesting. This can enable fast-forwarding lagging sources in latency sensitive use cases like realtime alerting. In such scenarios, wondering if there can be a back fill source operator (that is standby) and can process lag window through some broadcast state of start, stop offset pairs.