From db612b6c79c01dbde03eb85d2ebe6454e3c91bd0 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 6 Jul 2024 00:06:14 +0200
Subject: [PATCH] Outer Join!

---
 pom.xml                                                       | 2 +-
 .../kafka/wordcount/counter/StreamStreamJoinTopologyTest.java | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/pom.xml b/pom.xml
index 4e264b6..c7173ed 100644
--- a/pom.xml
+++ b/pom.xml
@@ -12,7 +12,7 @@
 	</parent>
 
 	<groupId>de.juplo.kafka.streams.demos</groupId>
-	<artifactId>stream-stream--left-join</artifactId>
+	<artifactId>stream-stream--outer-join</artifactId>
 	<version>1.0.0-SNAPSHOT</version>
 
 	<name>Outcome of a Left Stream/Stream-Join</name>
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 1d39a00..66ce22a 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
@@ -31,7 +31,7 @@ public class StreamStreamJoinTopologyTest
     KStream<String, String> right = builder.stream(RIGHT);
 
     left
-        .leftJoin(
+        .outerJoin(
             right,
             (valueLeft, valueRight) -> valueLeft + "-" + valueRight,
             JoinWindows.ofTimeDifferenceAndGrace(
@@ -96,7 +96,7 @@ public class StreamStreamJoinTopologyTest
     assertThatOutcomeIs("F-null");
 
     sendLeftAt("G", 100);
-    assertThatOutcomeIs();
+    assertThatOutcomeIs("null-f");
   }
 
 
-- 
2.20.1