Hi Yaroslav, The test I did was just using earliest, I'll test with committed offset again, thanks.
Regards, Alexis. On Thu, 14 Jul 2022, 20:49 Yaroslav Tkachenko, <yaros...@goldsky.io> wrote: > 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. >> >>
