[kafka] 02/02: HOTFIX: The cherry-pick for https://github.com/apache/kafka/pull/7207 to 2.1 causes a failure in AssignedStreamsTasksTest

[bb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bbejeck pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git

commit 6560203d20e818515d5b8c961fa648788c684cd6
Author: Bill Bejeck <bi...@confluent.io>
AuthorDate: Wed Sep 4 11:21:11 2019 -0400

    HOTFIX: The cherry-pick for https://github.com/apache/kafka/pull/7207 to 2.1 causes a failure in AssignedStreamsTasksTest
---
 .../kafka/streams/processor/internals/AssignedStreamsTasksTest.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java
index 349c463..3849047 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java
@@ -503,8 +503,7 @@ public class AssignedStreamsTasksTest {
 
         final StateDirectory stateDirectory = new StateDirectory(
             StreamTaskTest.createConfig(true),
-            time,
-            true);
+            time);
 
         final StreamTask task = new StreamTask(
             new TaskId(0, 0),
@@ -517,7 +516,8 @@ public class AssignedStreamsTasksTest {
             stateDirectory,
             null,
             time,
-            () -> producer);
+            () -> producer,
+            metrics.sensor("dummy"));
 
         assignedTasks.addNewTask(task);
         assignedTasks.initializeNewTasks();