Hello,

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) ?

B.R.

Reply via email to