flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gwenhael Pasquiers <gwenhael.pasqui...@ericsson.com>
Subject Flink 0.9.1 Kafka 0.8.1
Date Thu, 10 Sep 2015 14:26:32 GMT
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 ?



View raw message