Hi Wendong, why do you exclude the kafka dependency from the `flink-connector-kafka`? Do you want to use your own kafka version?
I'd recommend you to build a fat jar instead of trying to put the right dependencies in `/lib`. Here [1] you can see how to build a fat jar with sbt. Cheers, Till [1] http://stackoverflow.com/questions/28459333/how-to-build-an-uber-jar-fat-jar-using-sbt-within-intellij-idea On Sat, Jul 18, 2015 at 12:40 AM, Wendong <wendong....@gmail.com> wrote: > Hi Till, > > Thanks for the information. I'm using sbt and I have the following line in > build.sbt: > > libraryDependencies += "org.apache.flink" % "flink-connector-kafka" % > "0.9.0" exclude("org.apache.kafka", "kafka_${scala.binary.version}") > > Also, I copied flink-connector-kafka-0.9.0.jar under <flink_root_dir>/lib/, > but there is still ClassNotFoundException for KafkaSink. > > I appreciate it if you have any suggestion. > > Wendong > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2144.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
