Re: Old offsets consumed from Kafka after Flink upgrade to 1.9.1 (from 1.2.1)

2020-01-23 Thread Somya Maithani
Hey, Any ideas about this? We are blocked on the upgrade because we want async timer checkpointing. Regards, Somya Maithani Software Developer II Helpshift Pvt Ltd On Fri, Jan 17, 2020 at 10:37 AM Somya Maithani wrote: > Hey Team, > > *Problem* > Recently, we were trying to u

Old offsets consumed from Kafka after Flink upgrade to 1.9.1 (from 1.2.1)

2020-01-16 Thread Somya Maithani
flink-connector-kafka-0.10_2.11 > ${flink.version} > > > org.apache.flink > flink-statebackend-rocksdb_2.12 > ${flink.version} > > Do we know why this would be happening? Regards, Somya Maithani Software Developer II Helpshift Pvt Ltd