Hi Alexis, Do you use OffsetsInitializer.committedOffsets() to specify your Kafka consumer offsets? In this case, it should get the offsets from Kafka and not the state.
On Thu, Jul 14, 2022 at 11:18 AM Alexis Sarda-Espinosa < sarda.espin...@gmail.com> wrote: > Hello, > > Regarding the new Kafka source (configure with a consumer group), I found > out that if I manually change the group's offset with Kafka's admin API > independently of Flink (while the job is running), the Flink source will > ignore that and reset it to whatever it stored internally. Is there any way > to prevent this? > > Regards, > Alexis. > >
