You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Paul Lam <pa...@gmail.com> on 2018/11/01 02:17:30 UTC

Re: Kafka offset behaviour when restarting job from savepoint

Hi Anil,

Sure. You could have a look at FlinkKafkaConsumerBase.java.

Best,
Paul Lam

> 在 2018年11月1日，03:37，Anil <an...@gmail.com> 写道：
> 
> Hey Paul. Can you please point me to the code in Flink. Thanks!
> 
> 
> 
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/