MINOR: fix test after upstream change

Upstream fix: apache/kafka#14426
confluentinc · Mar 6, 2024 · 56a57d8 · 56a57d8
1 parent 909f9d6
commit 56a57d8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/test/java/io/confluent/examples/streams/StreamToStreamJoinIntegrationTest.java b/src/test/java/io/confluent/examples/streams/StreamToStreamJoinIntegrationTest.java
@@ -134,6 +134,7 @@ public void shouldJoinTwoStreams() {
       impressionInput.pipeKeyValueList(inputAdImpressions);
       clickInput.pipeKeyValueList(inputAdClicks);
       // Flush result
+      topologyTestDriver.advanceWallClockTime(Duration.ofSeconds(1L));
       impressionInput.pipeInput("dummy", "dummy", currentMs + windowSize.toMillis() * 3);
 
       //