When you cancel and restart a Flink job (without a savepoint), it does not use the checkpoint data, and uses the behavior you defined in the Kafka consumer to decide where to start from (consumer group, latest, or earliest).
On Wed, Aug 3, 2016 at 11:26 AM, Janardhan Reddy < [email protected]> wrote: > Hi, > > Is there a way to read from latest offset in kafka consumer on restart. > Or can we somehow start flink ignoring previous checkpointed data. > > Thanks >
