KStreamの互換​​性のないタイプ

Question

文字列を使用してコード部分で何かを試していましたが、以下のコードを思いついたので、コードの構文上の問題を助けてください。二KStream文で

KStreamBuilder builder = new KStreamBuilder(); 
KStream<String, String> textlines = builder.stream("INTOPIC"); 
KStream<String, String> mstream = textlines 
    .foreach(new ForeachAction<String, String>(){ 
     public void apply(String key, String value){ 
      String str=value.replace("[",""); 
      for(int y=0; y<str.length(); y++){ 
       //System.out.print(str.charAt(y)); 
      } 
      //System.out.print("\n"); 
     } 
    }); 
mstream.to("OUTTOPIC"); 

それは互換性のない型を示している..... 私はで動作するように置き換えるロジックをしたいし、それがテキストラインの変数に影響を与えるべきです。 ありがとうございます。

Answer 1

foreachの結果はvoidであり、次の値はKStreamではありません。あなたはデータを変換したい場合は、...代わりにmapを使用する必要が

コードになります方法（あなたがいない場合は、同様のキーを変更する必要がある場合は特に - 次のバリアントを参照）、以下：

KStreamBuilder builder = new KStreamBuilder(); 
KStream<String, String> textlines = builder.stream("INTOPIC"); 
KStream<String, String> mstream = textlines 
    .map((key, value) -> new KeyValue<>(key, value.replace("[","")))); 
mstream.to("OUTTOPIC"); 

か、以下で行3-4を置き換えることができます（それがより良い実行されてしまいます）：

KStream<String, String> mstream = textlines 
    .mapValues(value -> value.replace("[",""));