flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gwenhael Pasquiers <gwenhael.pasqui...@ericsson.com>
Subject Kafka offset commits
Date Thu, 13 Apr 2017 14:55:04 GMT

We're going to migrate some applications that consume data from a Kafka 0.8 from Flink 1.0
to Flink 1.2.

We are wondering if the offset commitment system changed between those two versions: is there
a risk that the Flink 1.2-based application will start with no offset (thus will use either
the smallest or highest one) ?
Or can we assume that the Flink 1.2 app will resume its work at the same offset than the Flink
1.0 app stopped (if they use the same consumer group id) ?


View raw message