Kafka Streams JoinWindow 的数据

Kafka Streams JoinWindow's data

在 Kafka Streams 中,我使用 Stream/Stream 使用 JoinWindow 加入。

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

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

Note: retention time is based on event time, not wall-clock time.