Kafka Streams JoinWindowのデータ

Question

Kafka Streamsでは、私はJoinWindowを使用してストリーム/ストリーム結合を使用しています。

私が理解できるところでは、JoinWindowsはStoresを使用して実装され、その後両方のストリームのデータはRocksDBデータベースに格納されます。 しかし、イベント時間が終了すると（で定義された保存期間を（）まで過ぎたら、物理データはどうなりますか？それらはRocksDBデータベースから削除されていますか？

Answer 1

はい、保持時間が経過すると、RocksDBのデータは削除されます。同じ保持時間を適用した基礎となる変更履歴トピックからもデータが削除されます。

注：保持時間は、壁時計の時間ではなく、イベント時間に基づいています。