Thanks Stephan and Till. Since I couldn't make a working example of Flink and Kafka after struggling a week, I have to temporarily stop the evaluation work and switch to other tasks. I hope in the near future, someone can come up with a working sample of KafkaWordCount, similar to that of Spark sample, and it would greatly benefit the community.
Wendong Here are some comments on Java Classloading: - The Zookeeper code is implicitly loaded by the Kafka code. - When java implicitly loads a class at some point in the program, is uses the classloader of the class of that point in the program. Here it will use the class loader that loaded the Kafka code. - You have to make sure that the zookeeper dependency is where the kafka connector is. It will not work to have kafka in /lib and zookeeper in the fat jar, for example. But putting everything into the /lib folder should work. Note: Its important that this is available on all worker machines. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2259.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
