Flink - Datastream Typ Konvertierung - Fehler

Question

Ich versuche, die verarbeitete Wordcount in Flink zu einem Kafka-Thema zu schreiben. Fehler ---

"Die Methode addSink (SinkFunction>) in der Art Datastream> für die Argumente nicht anwendbar ist (FlinkKafkaProducer09)"

Für den Code wie unten -

DataStream<Tuple2<String, Integer>> stream1 = stream.flatMap(new LineSplitter()) 
    .keyBy(0).sum(1); 
stream1.print(); 
env.execute(); 

stream1.addSink(new FlinkKafkaProducer09<String>("WCFKTopic", new SimpleStringSchema(), 
    properties)); 
env.execute(); 

Dank im Voraus!

Answer 1

Der Eingabetyp Ihrer Senkenfunktion stimmt nicht mit dem Typ stream1 überein.

Versuchen Sie folgendes:

new FlinkKafkaProducer09<Tuple2<String, Integer>>(XXX);