Hi David, Hi Sohi, this should not be the case. If a savepoint/checkpoint is provided, Flink should always take the offsets from the state regardless of the `group.id` provided. Which Flink version and which FlinkKafkaConsumer version do you use?
Best, Konstantin On Mon, Feb 18, 2019 at 5:50 AM sohimankotia <sohimanko...@gmail.com> wrote: > Hi David, > > We are also running streaming jobs over Kafka source . > > Yes : Consumer Group Id needs to be set for Kafka source explicitly t . > > We are also using checkpointing and save points for persisting state . Any > time we change group id it starts from latest offset(default Kafka > connector > behavior) . > > > > > Thanks > Sohi > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ > -- Konstantin Knauf | Solutions Architect +49 160 91394525 <https://www.ververica.com/> Follow us @VervericaData -- Join Flink Forward <https://flink-forward.org/> - The Apache Flink Conference Stream Processing | Event Driven | Real Time -- Data Artisans GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Data Artisans GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Dr. Kostas Tzoumas, Dr. Stephan Ewen
