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



我正试图将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();

提前感谢!

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

试试这个:

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

相关内容

  • 没有找到相关文章

最新更新