From 7d7ce8b4f08914497e8428bead36811bf4aaa307 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 8 Jul 2024 16:29:40 +0200
Subject: [PATCH] Vorschlag:2-suppressed

---
 .../juplo/kafka/wordcount/counter/AggregationTopologyTest.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 1b2b03d..7c0be99 100644
--- 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()
-- 
2.20.1