rebase

apache · Mar 6, 2020 · d4c4425 · d4c4425
1 parent 84ccecb
commit d4c4425
Showing 1 changed file with 1 addition and 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
@@ -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,