From 1f5e3fef1878f46357b408de0a8441daf7f09ef7 Mon Sep 17 00:00:00 2001
From: Chia-Ping Tsai <chia7712@gmail.com>
Date: Fri, 4 Dec 2020 18:43:57 +0800
Subject: [PATCH] HOTFIX: fix failed build caused by StreamThreadTest

---
 .../kafka/streams/processor/internals/StreamThreadTest.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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() {