java - Kafka Streams JoinWindow 的数据

Question

在 Kafka Streams 中，我使用的是使用 JoinWindow 的 Stream/Stream 连接。

据我了解，JoinWindows 是使用 Stores 实现的，然后两个流的数据都存储在 RocksDB 数据库中。但是，一旦事件时间到期（超过了until()中定义的保留时间），物理数据会发生什么情况？它们是否从 RocksDB 数据库中删除？

Answer 1

是的，保留时间过后，RocksDB 中的数据将被删除。数据也会从应用相同保留时间的基础变更日志主题中删除。

注意：保留时间基于事件时间，而不是挂钟时间。