Ok It is working now
I had to change a few dependency with the _2.11 suffix
Thanks
Sylvain
org.apache.flink
flink-java
${flink.version}
o
Hi,
Thanks for your reply, but I am still a bit confuse.
I have downloaded flink-0.10.1-bin-hadoop27-scala_2.11.tgz
and kafka_2.11-0.9.0.0.tgz
I did not install myself Scala
Now tell me if I understand correctly.
Depending on the version of Flink I have (in my case the scala 2.11) I must
spec
Do I need to go to Flink 1.0 or the downgrade to Kafka 0.8 ?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Simple-Flink-Kafka-Test-tp4828p4829.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
}
}).addSink(new FlinkKafkaProducer("localhost:9092", "demo2", new
SimpleStringSchema()));
System.out.println("Step E");
env.exe
