KSQL加入KTable-KTable时单独设置状态保留时间

Question

在 KafaStream 中使用 KTable join 时，我可以为 changelog 主题和 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 尚不支持。

KSQL加入KTable-KTable时单独设置状态保留时间

Set retention time for states indivisually when joining KTable-KTable using KSQL

ksqldb