Flink - Datastream型変換 - エラー

Question

Flipで処理されたワードカウントをkafkaトピックに書き込もうとしています。以下のようにコードのエラーです---

"方法addSink（SinkFunction>）型の中でDataStream>引数には適用されません（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);