Hi Marco, > https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/kafka/#additional-properties In the new KafkaSource, you can configure it in your properties. You can take a look at `KafkaSourceOptions#COMMIT_OFFSETS_ON_CHECKPOINT` for the specific config, which is default to true if you have checkpoints enabled.
Best, Mason On Fri, Nov 19, 2021 at 7:45 AM Marco Villalobos <mvillalo...@kineteque.com> wrote: > The FlinkKafkaConsumer that will be deprecated has the method > "setCommitOffsetsOnCheckpoints(boolan)" method. > > However, that functionality is not the new KafkaSource class. > > How is this behavior / functionality configured in the new API? > > -Marco A. Villalobos > > >
