Re: Reset Kafka Consumer using Flink Consumer 10 API

2017-08-27 Thread sohimankotia
ion-configuration> ,are not present in *FlinkKafkaConsumer010*. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Reset-Kafka-Consumer-using-Flink-Consumer-10-API-tp15077p15181.html Sent from the Apache Flink User Mailing List archive. m

Re: Reset Kafka Consumer using Flink Consumer 10 API

2017-08-25 Thread Robert Metzger
t; in.dailyhunt.cis.enrichment.pings.simulate.ReplayTest. > main(ReplayTest.java:27) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java: > 62) > at > sun.reflect.

Reset Kafka Consumer using Flink Consumer 10 API

2017-08-22 Thread sohimankotia
apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528) ... 13 more Thanks and Regards Sohanvir -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Reset-Kafka-Consumer-using-Flink-Consumer-10-API-tp15077.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.