Hi Team, 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.* Jira Ticket : https://issues.apache.org/jira/browse/FLINK-32038 Thanks & Regards, Pritam Agarwala Senior Data Engineer
