使用 KSQL 加入 KTable-KTable 时,单独设置状态的保留时间



在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 尚不支持此功能。

最新更新