From: Kai Moritz <kai@juplo.de>
Date: Mon, 8 Jul 2024 14:29:40 +0000 (+0200)
Subject: Vorschlag:2-suppressed
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=7d7ce8b4f08914497e8428bead36811bf4aaa307;p=demos%2Fkafka%2Fwordcount

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 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()