From: Kai Moritz <kai@juplo.de>
Date: Fri, 5 Jul 2024 22:25:17 +0000 (+0200)
Subject: Forced emidiate emitt of join-results
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=bb83ad13eeebaef249fa3b7fe51d078bbbc68963;p=demos%2Fkafka%2Fwordcount

Forced emidiate emitt of join-results
---

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
index d17dcde..1d39a00 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
@@ -44,6 +44,7 @@ public class StreamStreamJoinTopologyTest
     Properties properties = new Properties();
     properties.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.StringSerde.class);
     properties.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.StringSerde.class);
+    properties.put(StreamsConfig.InternalConfig.EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX, 0l);
 
     TopologyTestDriver testDriver = new TopologyTestDriver(topology, properties);