flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer
Date Tue, 28 Jul 2015 07:45:53 GMT
Yes, I was running exactly that code. This is a repository containing the
files: https://github.com/rmetzger/scratch/tree/flink-sbt-master
Here is the program:
https://github.com/rmetzger/scratch/blob/flink-sbt-master/src/main/scala/org/myorg/quickstart/Job.scala

On Tue, Jul 28, 2015 at 2:01 AM, Wendong <wendong.zhu@gmail.com> wrote:

> Just to confirm: are you able to compile and run the program of testing
> Kafka
> similar to the following?
>
> import org.apache.kafka.clients.producer.{ProducerConfig, KafkaProducer,
> ProducerRecord}
> import org.apache.flink.streaming.api.environment._
> import org.apache.flink.streaming.connectors.kafka
> import org.apache.flink.streaming.connectors.kafka.api._
> import org.apache.flink.streaming.util.serialization._
> import org.apache.flink.api.common.typeinfo._
>
> object TestKafka {
>   def main(args: Array[String]) {
>     val env = StreamExecutionEnvironment.getExecutionEnvironment
>     val stream = env
>       .addSource(new KafkaSource[String]("localhost:2181", "test", new
> SimpleStringSchema))
>       .addSink(new KafkaSink[String]("localhost:2181", "test", 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.
>

Mime
View raw message