データレコードをいつまで待機するかを制御します。grace-period)、レコードは破棄され、そのウィンドウでは処理されません。現実には順序外のレコードが生じる可能性は常にあり、アプリケーションで適切に対処することが必要です。順序外のレコードがどのように処理されるかは、システムの時間セマンティクスによって決まります。あるため、順序外レコードの概念は適用されません。同様にインジェスト時刻の場合、ブローカーはトピックの追加順に基づいて昇順にタイムスタンプを割り当て、タイムスタンプはインジェスト時刻のみを示します。示すタイムスタンプがプロデューサーによって設定されるイベント時刻セマンティクスでだけです。つのプロデューサーが同じトピックパーティションに書き込む場合、イベントの追加順序は保証されません。(イベント時刻)の順序外のレコードを適切に処理できます。取って代わるもので、ウィンドウの終了後、そのウィンドウで順序外のイベントが許容される期間をより明確に定義します。猶予期間はウィンドウの最終結果の扱いに直接的に関係するもので、保持時間の下限でもあります。保持時間も引き続き構成可能ですが、ウィンドウストアの低レベルプロパティとなっています。日)保持するように選択することもできます。大容量のストレージを備えたリモートの分散システムで、最後のウィンドウを超えて、さらには無期限にでも対話型クエリをサポートできます。メモリー内の実装向けにはイベントの保持時間を短くすることができます。対話型クエリを使用すると、ストリーム処理層を軽量の組み込みデータベースのように扱い、ストリーム処理アプリケーションの最新のステートを直接クエリできます。そのステートを事前に外部データベースや外部ストレージに具現化する必要はありません。対話型クエリはアーキテクチャを単純化し、よりアプリケーション中心のアーキテクチャを実現します。つのアーキテクチャを比較する図を示します。番目のアーキテクチャは使用するものです。どちらのアーキテクチャが適しているかは、具体的なユースケースによって異なります。つの方法に限定されるのではなく、適切な方法を選択して構成できる柔軟性が与えられるという点です。ハイブリッドアーキテクチャを実装するという選択肢もあります。経由で)共有することができます。複雑さが増し、アーキテクチャのフットプリントが大きい。簡素化され、よりアプリケーション中心のアーキテクチャ。以下に、対話型クエリを活かしたアプリケーションのユースケースの例をいくつか示します。アプリケーションに直接クエリを送信できます。アプリケーションは、ゲーム世界におけるプレイヤーの最新の位置を継続的に追跡します。アプリケーションにクエリを直接送信して、プレイヤーの現在位置を友人や家族に表示し、一緒に参加するように招待することができます。同様に、ゲームベンダーでは、このデータを使用してプレイヤーの不自然なホットスポットを特定できます。このようなホットスポットは、バグや操作上の問題を示している可能性があります。アプリケーションが、ユーザートランザクションに異常や疑わしい動作がないかどうかを継続的に分析します。アプリケーションにクエリを直接送信して、疑わしいと見なされたユーザーのアクセスを拒否できます。アプリケーションが、リアルタイムで収集されるユーザーのリスニング傾向を基に、さまざまな音楽ジャンルの最新トップチャートを継続的に計算します。ミュージックストアのモバイルアプリケーションやデスクトップアプリケーションでは、ユーザーがストアを閲覧しているときに、対話的にクエリを実行して最新チャートを取得できます。処理の保証がサポートされます。セマンティクスレコードが失われることはありませんが、再デリバリーされる場合があります。ストリーム処理アプリケーションで障害が発生した場合、データレコードが失われることや処理されなくなることはありませんが、一部のデータレコードが再度読み取られ、再処理される場合があります。デフォルトで有効になっています(processing.guarantee="at_least_once")。