Re: Flink Kafka example in Scala

saved me 4 days. > > Wendong > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2198.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink Kafka example in Scala

.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2198.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Flink Kafka example in Scala

>>>>> >>>>> Thanks for the information. I'm using sbt and I have the following >>>>> line in >>>>> build.sbt: >>>>> >>>>> libraryDependencies += "org.apache.flink" % "flink-connector-kafka" % >

Re: Flink Kafka example in Scala

gt; in >>>> build.sbt: >>>> >>>> libraryDependencies += "org.apache.flink" % "flink-connector-kafka" % >>>> "0.9.0" exclude("org.apache.kafka", "kafka_${scala.binary.version}") >>>> >

Re: Flink Kafka example in Scala

dencies += "org.apache.flink" % "flink-connector-kafka" % >>> "0.9.0" exclude("org.apache.kafka", "kafka_${scala.binary.version}") >>> >>> Also, I copied flink-connector-kafka-0.9.0.jar under >>> /lib/, >>>

Re: Flink Kafka example in Scala

link-connector-kafka-0.9.0.jar under >> /lib/, >> but there is still ClassNotFoundException for KafkaSink. >> >> I appreciate it if you have any suggestion. >> >> Wendong >> >> >> >> -- >> View this message in context: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2144.html >> Sent from the Apache Flink User Mailing List archive. mailing list >> archive at Nabble.com. >> > >

Re: Flink Kafka example in Scala

tFoundException for KafkaSink. > > I appreciate it if you have any suggestion. > > Wendong > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2144.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink Kafka example in Scala

so, I copied flink-connector-kafka-0.9.0.jar under /lib/, but there is still ClassNotFoundException for KafkaSink. I appreciate it if you have any suggestion. Wendong -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-t

Re: Flink Kafka example in Scala

java.net.URLClassLoader$1.run(URLClassLoader.java:366) Any clue? Thanks, Wendong -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2143.html Sent from the Apache Flink User Mailing List archive. mailing list archive at

Re: Flink Kafka example in Scala

eStringSchema)) >> .addSink(new KafkaSink[String]("localhost:2181", "test", new >> SimpleStringSchema)) >> >> Anything wrong? I already did "import >> org.apache.flink.streaming.connectors.kafka.api._". Class >> SimpleStringSchema &

Re: Flink Kafka example in Scala

.addSink(new KafkaSink[String]("localhost:2181", "test", new > SimpleStringSchema)) > > Anything wrong? I already did "import > org.apache.flink.streaming.connectors.kafka.api._". Class > SimpleStringSchema > was modified (see previous post). > &g

Re: Flink Kafka example in Scala

"test", new SimpleStringSchema)) Anything wrong? I already did "import org.apache.flink.streaming.connectors.kafka.api._". Class SimpleStringSchema was modified (see previous post). Thanks, Wendong -- View this message in context: http://apache-flink-user-mailing-list-archive.

Re: Flink Kafka example in Scala

context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2109.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink Kafka example in Scala

message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2109.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Flink Kafka example in Scala

tream.DataStreamSink.copy(DataStreamSink.java:30) >> at >> >> org.apache.flink.streaming.api.datastream.DataStream.addSink(DataStream.java:1341) >> at >> >> org.apache.flink.streaming.api.datastream.DataStream.print(DataStream.java:1029) >> .

Re: Flink Kafka example in Scala

message but didn't find useful information. > > Anyone can shed some light? > > Thanks! > > Wendong > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069p2071.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink Kafka example in Scala

Flink-Kafka-example-in-Scala-tp2069p2071.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Flink Kafka example in Scala

est", new > SimpleStringSchema)) > > I changed SimpleStringSchema to SerializationSchema which still doesn't > work. > > I am trying to transit from Spark to Flink, but the samples in Flink are > far > less than those in Spark. It would be very helpful if there is an example > of > KafkaWordCount in Scala similar to that in Spark. > > Thanks, > > Wendong > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Flink Kafka example in Scala

trying to transit from Spark to Flink, but the samples in Flink are far less than those in Spark. It would be very helpful if there is an example of KafkaWordCount in Scala similar to that in Spark. Thanks, Wendong -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-example-in-Scala-tp2069.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.