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

Reply via email to