Hi, I tried to use the latest 0.9.1 release but I got:
java.lang.NoSuchMethodError: org.apache.flink.util.NetUtils.ensureCorrectHostnamePort(Ljava/lang/String;)V at com.nventdata.kafkaflink.sink.FlinkKafkaTopicWriterSink.<init>(FlinkKafkaTopicWriterSink.java:69) at com.nventdata.kafkaflink.sink.FlinkKafkaTopicWriterSink.<init>(FlinkKafkaTopicWriterSink.java:48) at com.nventdata.kafkaflink.FlinkKafkaTopicWriterMain.main(FlinkKafkaTopicWriterMain.java:54) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:437) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353) at org.apache.flink.client.program.Client.run(Client.java:315) at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:582) at org.apache.flink.client.CliFrontend.run(CliFrontend.java:288) at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:878) at org.apache.flink.client.CliFrontend.main(CliFrontend.java:920) Thanks, Ferenc
