Hi Anil, Sure. You could have a look at FlinkKafkaConsumerBase.java.
Best, Paul Lam > 在 2018年11月1日，03:37，Anil <anilsingh....@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/
