flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Wendong <wendong....@gmail.com>
Subject Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer
Date Tue, 28 Jul 2015 00:01:27 GMT
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