diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java
index f90dc4bc174d5..33f7b70298374 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/KStreamKTableJoinIntegrationTest.java
@@ -319,7 +319,7 @@ public void apply(final String key, final Long value) {
             public boolean conditionMet() {
                 return remainingExpectedResult.isEmpty();
             }
-        }, "Never received expected result.");
+        }, 30000, "Never received all expected results.  Still waiting for " + remainingExpectedResult);
 
         final int expectedResultSize = expectedClicksPerRegion.size();
         final int expectedNumberOfOutputs = (cacheSizeBytes == 0)