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)
