Added forgotten input record from original example

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 4dedf0fe263cf5936ec5c01fd6e1f772976aec02..3812e86f569b51244c0d8a7483ced6e02780ef29 100644 (file)
--- 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();
   }