Pritam Agarwala created FLINK-32038: ---------------------------------------
Summary: OffsetCommitMode.Kafka_periodic with checkpointing enabled Key: FLINK-32038 URL: https://issues.apache.org/jira/browse/FLINK-32038 Project: Flink Issue Type: Improvement Reporter: Pritam Agarwala I need to get kafka-lag to prepare a graph and its dependent on kafka committed offset. Flink is updating the offsets only after checkpointing to make it consistent. 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 regularly since* *in any case flink doesn't use consumer committed offsets for recovery.* -- This message was sent by Atlassian Jira (v8.20.10#820010)