つの原因から順序外のデータの到着が引き起こされる可能性があります。トピックパーティション内で、レコードのタイムスタンプがオフセットとともに単調に増加していない。常にオフセット順にレコードの処理を試みるため、同じトピックパーティション内でタイムスタンプの大きい(ただしオフセットは小さい)レコードが、タイムスタンプの小さい(ただしオフセットは大きい)レコードよりも前に処理される可能性があります。複数のトピックパーティションを処理する状況で、アプリケーションが、すべてのパーティションにデータがバッファリングされるまで待機し、次に処理するレコードをタイムスタンプが最小のパーティションから選択するように構成されていない。この場合、後で他のトピックパーティションから取得されるレコードに、処理済みのレコードよりも小さいタイムスタンプが設定されていることがあり、実質的に古いレコードが新しいレコードの後に処理される結果となります。つのレコードしか考慮せず、過去に処理されたレコードの履歴も参照しないため、順序外のデータが処理ロジックに影響することはありません。集約と結合のようなステートフル操作では、順序外のデータによってアプリケーションロジックが不適切になることがあります。このような順序外のデータを処理するには、一般に、アプリケーションでステートの記録を待機する時間を長く確保する必要があります。これは、レイテンシ、コスト、正確性の間でトレードオフを図ることを意味します。ウィンドウ化された集約でこのようなトレードオフを実現するためのウィンドウオペレーターを構成できます。