Hello, I need to get kafka-lag to prepare a graph and dependent on kafka committed offset. Flink is updating the offsets only after checkpointing to make it consistent. Can I enable OffsetCommitMode.Kafka_periodic with checkpointing enabled ?? Default Behaviour as per doc : If checkpoint is enabled, but

consumer.setCommitOffsetsOnCheckpoints

set to false, then offset will not be committed at all even if the

enable.auto.commit

is set to true. So, when

consumer.setCommitOffsetsOnCheckpoints

set to false, shouldn't it fall back on the

enable.auto.commit

to do offset commit.