diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
index 59bb66f9f210d..157f9e5efcd58 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
@@ -2518,7 +2518,8 @@ public void runAndVerifyFailedStreamThreadRecording(final boolean shouldFail) {
             new AtomicInteger(),
             new AtomicLong(Long.MAX_VALUE),
             null,
-            e -> { }
+            e -> { },
+            null
         ) {
             @Override
             void runOnce() {