From d4c44254016f6c41f3429ab6a66dd7c203e0d482 Mon Sep 17 00:00:00 2001
From: abbccdda <boyang@confluent.io>
Date: Fri, 6 Mar 2020 15:58:03 -0800
Subject: [PATCH] rebase

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

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 5e3d4663c7028..1bb4c9c6c71cd 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
@@ -841,12 +841,11 @@ public void restore() {
 
         final StreamsMetricsImpl streamsMetrics =
             new StreamsMetricsImpl(metrics, CLIENT_ID, StreamsConfig.METRICS_LATEST);
+
         final StreamThread thread = new StreamThread(
             mockTime,
             config,
             null,
-            null,
-            null,
             consumer,
             consumer,
             changelogReader,