(ウィンドウ化) に実行さ.countByKey()れ、.forEach().
ウィンドウ化された値を取得し、それらを開始値と終了値とペアにして、これを新しいストリームに入れたいと思います。「従来の」プロデューサーでこれを行うことができますが、すべての作業を 1 つのアプリに保持したいと考えています (新しいトピックの値を処理する 2 つ目のアプリを用意するのではなく)。
はKTable<Windowed<String>, Long>.forEach()として入ってきますが、これを (またはを介して) KStream<String, String>トピックにチェーンする明白な演算子は見当たりません。.to().through()
これは可能ですか？質問に意味はありますか？