OSDir


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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 <anilsingh.jsr@xxxxxxxxx> 写道:
> 
> 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/