(外部結合を使用してマージされた) 2 つのトピックからのデータの順序を変更する必要があります。を使用しStateStoreて最新のシーケンスを保持し、再シーケンスされたメッセージでダウンストリーム ストリームの値を変更することをお勧めします。
単純化された問題:
(トピック A からの seq、トピック B からの seq) -> 出力への新しい seq (現在のシーケンスを に保持StateStore)
(10,100) -> 1
(11,101) -> 2
(12,102) -> 3
(...,...) -> ...
新しいシーケンスは、キー「currentSeq」の値として stateStore に格納されます。シーケンスはメッセージごとにインクリメントされ、stateStore に保存されます。