flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Janardhan Reddy <janardhan.re...@olacabs.com>
Subject Re: Reading from latest offset in kafka consumer on restart
Date Wed, 03 Aug 2016 09:36:54 GMT
How would checkpointing affect the offset.

On Wed, Aug 3, 2016 at 3:03 PM, Stephan Ewen <sewen@apache.org> 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 <
> janardhan.reddy@olacabs.com> 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
>>
>
>

Mime
View raw message