Hi Gwen, sorry that you ran into this issue. The implementation of the Kafka Consumer has been changed completely in 0.9.1 because there were some corner-case issues with the exactly-once guarantees in 0.9.0.
I'll look into the issue immediately. On Thu, Sep 10, 2015 at 4:26 PM, Gwenhael Pasquiers < gwenhael.pasqui...@ericsson.com> wrote: > Hi everyone, > > > > We’re trying to use consume a 0.8.1 Kafka on Flink 0.9.1 and we’ve run > into the following issue : > > > > My offset became OutOfRange however now when I start my job, it loops on > the OutOfRangeException, no matter what the value of auto.offset.reset is… > (earliest, latest, largest, smallest) > > > > Looks like it doesn’t fix the invalid offset and immediately goes into > error… Then Flink restarts the job, and failes again … etc … > > > > Do you have an idea of what is wrong, or could it be an issue in flink ? > > > > B.R. > > > > Gwenhaël PASQUIERS >
