Thanks for the example code! I'll try it out.
Wendong
--
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-tp2199p2294.html
Sent from the Apache Flink User Mailing List ar
t;, new
> JavaDefaultStringSchema))
>
> env.execute("Test Kafka")
> }
> }
>
>
>
> --
> 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-tp2199p2285.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2285.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Strategy in assembly) { (old) =>
>{
> case PathList("META-INF", xs @ _*) => MergeStrategy.discard
> case x => MergeStrategy.first
>}
> }
>
> //--------- End build.sbt ---
>
> //- Start project/assembly
-----
addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.12.0")
//- End project/assembly.sbt --
--
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-tp2199p2271.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
e 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
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.
>
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
>> ******************
>>
>>
>>
>>
>> Best regards
>> Hawin
>>
>> -Original Message-
>> From: Wendong [mailto:wendong@gmail.com]
>> Sent: Tuesday, July 21, 2015 5:16 PM
org.apache.kafka
> kafka-clients
> 0.8.2.1
>
> **
>
>
>
>
> Best regards
> Hawin
>
> -Original Message-
> From: Wendong [mailto:wendong@gmail.com]
> Sent: Tuesday, July 21, 2015 5:16 PM
&g
21, 2015 5:16 PM
To: user@flink.apache.org
Subject: Re: Flink Kafka cannot find
org/I0Itec/zkclient/serialize/ZkSerializer
Hi Hawin,
I'm using sbt as shown in the original post. I tried using maven and
pom.xml, but got different NoClassDefFoundError: com/yammer/metrics/Metrics.
I've
ng-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
> ZkSerializer
> in flink.streaming.connectors.kafka.api.KafkaSource.open().
>
>
>
> --
> 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-tp2199p2220.html
>
chive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2220.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
ext:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-cannot-find-org-I0Itec-zkclient-serialize-ZkSerializer-tp2199p2218.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
link-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.
>
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
.tasks.SourceStreamTask.invoke(SourceStreamTask.java:52)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassNotFoundException:
org.I0Itec.zkclient.serialize.ZkSerializer
at java.net.URLClassLoader$1.run(U
18 matches
Mail list logo
