flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Flink Kafka example in Scala
Date Mon, 20 Jul 2015 07:42:15 GMT
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.zhu@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.
>

Mime
View raw message