在KafaStream中使用KTable加入时,我可以为更改日志主题和rocksDB单独设置保留时间,如下所示:
clickStream.groupByKey()
.windowedBy(TimeWindows.of(Duration.ofSeconds(200)))
.reduce((oldValue, newValue) -> newValue, Materialized.<Integer, String,
WindowStore<Bytes, byte[]>>as("click").withRetention(Duration.ofSeconds(30000)));
使用 ksql(KTable-KTable( 进行连接时,我可以做同样的事情吗?
例如:
select * from clicks
left join conversions on clicks->param = conversions->param
并且我希望对点击 KTable 和转化 KTable 单独设置保留时间,例如,点击为 1 周,转化为 1 个月。
KSQL 尚不支持此功能。