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....@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.
>
