使用KSQL连接KTable-KTable时，直观地设置状态的保留时间

Question

在KafaStream中使用KTable join时，我可以分别为changelog topic和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个月的转换。

Answer 1

KSQL还不支持这一点。