From 2fe0c2b692eb6e96c528b0febf38687889085110 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 5 Jul 2024 23:54:30 +0200
Subject: [PATCH] Added forgotten input record from original example

---
 .../kafka/wordcount/counter/StreamStreamJoinTopologyTest.java  | 3 +++
 1 file changed, 3 insertions(+)

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 4dedf0f..3812e86 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
@@ -91,6 +91,9 @@ public class StreamStreamJoinTopologyTest
     inLeft.pipeInput(recordOf("F", 60));
     assertThatOutcomeIs();
 
+    inRight.pipeInput(recordOf("f", 80));
+    assertThatOutcomeIs();
+
     inLeft.pipeInput(recordOf("G", 100));
     assertThatOutcomeIs();
   }
-- 
2.20.1