flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Reading from latest offset in kafka consumer on restart
Date Wed, 03 Aug 2016 09:33:15 GMT
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

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

View raw message