Hei, Looking at the flink documentation for kafkasource I see the following values for starting offset:
OffsetInitializer.earliest OffsetInitializer.latest OffsetInitializer.commitedOffset(OffsetResetStrategy.EARLIEST) >From what I understand OffsetInitializer.earliest uses earliest offset the first time but later deployments will use the committed offset in the flink state to resume from there. If that is the case what is the difference between OffsetInitializer.earliest and commitedOffset(OffsetResetStrategy.EARLIEST) if both continue from the committed offset after redeployment? Thanks! Oscar
