popular: 1.4.0 - Switched to Sliding Window

diff --git a/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java
index 74aa2c6..367277b 100644 (file)
--- a/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/popular/PopularStreamProcessor.java
@@ -59,7 +59,7 @@ public class PopularStreamProcessor
                                .map((key, userWord) -> new KeyValue<>(Word.of(userWord.getWord()), Word.of(userWord.getWord())))
                                .peek((key, value) -> log.info("mapped: {} -> {}", key, value))
                                .groupByKey()
-                               .windowedBy(TimeWindows.ofSizeWithNoGrace(WINDOW_SIZE))
+                               .windowedBy(SlidingWindows.ofTimeDifferenceWithNoGrace(WINDOW_SIZE))
                                .count(
                                                Materialized
                                                                .<Word, Long>as(windowBytesStoreSupplier)