Search code examples
apache-flink

Flink checkpoint disabled and auto.offset.commit is false


We have flink app which consumes record from kafka and transform and produce to kafka.

We are using Flink version 1.16

Want to understand the behaviour of offset commit/management with below configuration .

  1. flink checkpoint disabled
  2. auto.commit.enabled = false
  3. offset.reset = earliest

Solution

  • If you disable both Flink checkpoints and Kafka Client auto committing, no offsets will be committed to Kafka. If you restart your Flink application, it will read from earliest everything you're starting it.