Thanks, In the mean time we’ll go back to 0.9.0 ☺
From: Robert Metzger [mailto:rmetz...@apache.org] Sent: jeudi 10 septembre 2015 16:49 To: user@flink.apache.org Subject: Re: Flink 0.9.1 Kafka 0.8.1 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<mailto: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
