You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2019/08/30 01:19:06 UTC
[kafka] branch 2.3 updated: HOTFIX: AssignedStreamsTasksTest lacks
one parameter
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new 2a38ae7 HOTFIX: AssignedStreamsTasksTest lacks one parameter
2a38ae7 is described below
commit 2a38ae7c492292282ed4c42845d4348e2eb166d5
Author: Guozhang Wang <wa...@gmail.com>
AuthorDate: Thu Aug 29 18:18:31 2019 -0700
HOTFIX: AssignedStreamsTasksTest lacks one parameter
---
.../kafka/streams/processor/internals/AssignedStreamsTasksTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 ca51a3b..1833052 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
@@ -519,7 +519,8 @@ public class AssignedStreamsTasksTest {
stateDirectory,
null,
time,
- () -> producer);
+ () -> producer,
+ metrics.sensor("dummy"));
assignedTasks.addNewTask(task);
assignedTasks.initializeNewTasks();