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.
在 Kafka Streams 中,我使用 Stream/Stream 使用 JoinWindow 加入。
据我了解,JoinWindows是使用Stores实现的,然后两个流的数据都存储在RocksDB数据库中。 但是,一旦事件时间到期(超过 until() 中定义的保留时间),物理数据会发生什么情况?它们是否已从 RocksDB 数据库中删除?
是的,保留时间过后,RocksDB 中的数据被删除。数据也从应用相同保留时间的基础变更日志主题中删除。
Note: retention time is based on event time, not wall-clock time.