envirmoent:
flink 1.0.2
kafka 0.8
<artifactId>flink-connector-kafka-0.8_2.10</artifactId>
Getting below exception
Caused by: java.lang.NoClassDefFoundError: kafka/javaapi/consumer/SimpleConsumer
I have added below jars in fink/LIB
flink-connector-kafka-0.8_2.10-1.0.2.jar
flink-connector-kafka-base_2.10-1.0.2.jar
Please let me know what else i need to add to make kafka integrated with flink
Locked
