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 08:28:23 GMT
Why not trying maven instead?

On Mon, Jul 20, 2015 at 10:23 AM, Anwar Rizal <anrizal05@gmail.com> wrote:

> I do the same trick as Wendong to avoid compilation error of sbt
> (excluding kafka_$(scala.binary.version) )
>
> I still don't manage to make sbt pass scala.binary.version to maven.
>
> Anwar.
>
> On Mon, Jul 20, 2015 at 9:42 AM, Till Rohrmann <trohrmann@apache.org>
> wrote:
>
>> 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