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.
