Flink-数据流类型转换-错误

Question

我正试图将Flink中处理过的wordcount写入一个kafka主题。错误为---

"DataStream>类型中的方法addSink（SinkFunction>）不适用于参数（FlinkKafkaProducer09）"

对于以下代码-

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();

提前感谢！

Answer 1

接收器函数的输入类型与stream1的类型不匹配。

试试这个：

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