How would checkpointing affect the offset. On Wed, Aug 3, 2016 at 3:03 PM, Stephan Ewen <[email protected]> wrote:
> 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 >> > >
