KafkaStreams TimeWindows.of 를 최신으로 변경하는 방법

[saechimdaeki]

.windowedBy(TimeWindows.of(Duration.ofMinutes(5)).grace(Duration.ofSeconds(30))))

기존에 이런식으로 고정 창 크기가 5분이고 유예 기간이 30초인 TimeWindows 개체를 만드는 방법이 있었다.

https://kafka.apache.org/27/javadoc/org/apache/kafka/streams/kstream/TimeWindows.html

이 방법은 deprecated가 되었음을 알 수 있는데 유예기간이 있게 설정하고 싶다면 다음과 같이할 수 있다

.windowedBy(TimeWindows.ofSizeAndGrace(Duration.ofMinutes(5),Duration.ofSeconds(30)))

유예기간이 없게 설정하고 싶다면 이 또한 명확한 메소드가 제공되는데 다음과 같다

.windowedBy(TimeWindows.ofSizeWithNoGrace(Duration.ofMinutes(5)))