Hi, Are you running this locally or in a cluster environment? Did you put the zkClient-0.5.jar in the /lib directory of every node (also task managers)?
It seems like sbt should include the zkClient dependency in the fat jar. So there might be something wrong with your build process. Best regards, Max On Tue, Jul 21, 2015 at 7:10 AM, Wendong <wendong....@gmail.com> wrote: > to be specific, the error occurs at: > > > org.apache.flink.*streaming.connectors.kafka.api.KafkaSource.initializeConnection*(KafkaSource.java:175) > > > > -- > 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-tp2199p2200.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
