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