Hello, I have looking for this for a while but couldn’t find anything! According to the docs when

the Flink Kafka Consumer will commit the offsets stored in the checkpointed states when the checkpoints are completed.

Does it mean when Flink stops (not cancel) then Flink Kafka consumer will commit the offset given the fact that the Flink will create a checkpoint before actually stoping the job?

If you make a snapshot, then it will commit the offsets. Keep in mind that it won’t use them when restarting the job!

Thanks Martijn, one more clarification. Does it also commits during the checkpoint or only savepoint Does snapshot means savepoint or checkpoint?

Snapshots is agnostic: it means either savepoint or checkpoint

Perfect, thanks for the clarification 👍