Vorschlag:2-suppressed

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java
index 1b2b03d4a758d6b343b34e2745e9b0cfcf081af0..7c0be995fb375240bed38db520230ff2a19419e3 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/AggregationTopologyTest.java
@@ -47,7 +47,8 @@ public class AggregationTopologyTest
         .windowedBy(slidingWindow)
         .count(Materialized.<String, Long, WindowStore<Bytes, byte[]>>as("aggregated-store")
             .withKeySerde(Serdes.String())
-            .withValueSerde(Serdes.Long()));
+            .withValueSerde(Serdes.Long()))
+        .suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded()));
 
     aggregatedTable
         .toStream()