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 74aa2c602b34e253a2776126b33776f57dfad5d4..367277b040a840ca1918b6e023e9c9e09c4a085d 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)