0
スプリッタとアグリゲータの作成方法については、Stream Cloud Data Flow(Stream XDではなく)に固有のいくつかの例を指し示すことができますか?Spring Cloudデータフローアグリゲータの例
特に、メッセージの非自明な分割と結合。複雑なストリームの例はありません。分割後にメッセージを集約しているストリームを定義する方法、生成されたメッセージのルーターと別の処理についてはどうしたら後で集計するのですか?
PS:長い質問のため申し訳ありませんが、必要に応じて明確にします。感謝! ありがとう!
ありがとうございます!私は提供されたリンクを読みましたが、誰かがこの質問を見つけた場合に役立つものがいくつかあります:[リンク] https://github.com/spring-cloud/spring-cloud-stream-app-startersそれには他の初心者が含まれています。私は非常にシンプルな@Agregatorアノテーションを持つメソッド、パラメータとしてMessageのリストと単一のMessageの結果を返すメソッドに基づいて、ジェネレータを終了しました...まだ複雑なストリームの例の問題に答えることはできません。 – ka2
私はこれを参考にして答えとしてマークしますが、より複雑な例を公開するのはいいと思います... – ka2