Hi Kafka Streams user, I have this usage of Kafka Streams and it works well that sets retention time in KTable, both in the internal topics and RocksDB local states.
final KStream<Integer, String> eventStream = builder .stream("events", Consumed.with(Serdes.Integer(), Serdes.String()) .withOffsetResetPolicy(Topology.AutoOffsetReset.EARLIEST)); eventStream.groupByKey() .windowedBy(TimeWindows.of(Duration.ofSeconds(200)).until(Duration.ofSeconds(3000).toMillis())) .reduce((oldValue, newValue) -> newValue); I saw until() is deprecated from 2.2. What would be the replacement of such usage? I checked the Materialized related document but cannot find any Best, Sendoh