Hi Anil,
Sure. You could have a look at FlinkKafkaConsumerBase.java.
Best,
Paul Lam
> 在 2018年11月1日，03:37，Anil 写道：
>
> 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/
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/
Hi Bend,
The offsets would be restored from the savepoint. Flink would only fallback to
use the offsets on the brokers if there are no offset in its states.
Best,
Paul Lam
> 在 2018年10月31日，17:13，
> 写道：
>
> Hi
> Let’s say we have a job which reads from a Flink kafka source
> (FlinkKafkaCons
