diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ReadOnlyTaskTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ReadOnlyTaskTest.java index 9b780dee6bbc3..e25c7014c68e5 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ReadOnlyTaskTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ReadOnlyTaskTest.java @@ -17,6 +17,7 @@ package org.apache.kafka.streams.processor.internals; import org.apache.kafka.common.TopicPartition; +import org.apache.kafka.common.utils.Time; import org.apache.kafka.streams.processor.TaskId; import org.junit.jupiter.api.Test; @@ -184,6 +185,9 @@ private Object[] getParameters(final Class[] parameterTypes) throws Exception case "java.lang.Iterable": parameters[i] = Collections.emptySet(); break; + case "org.apache.kafka.common.utils.Time": + parameters[i] = Time.SYSTEM; + break; default: parameters[i] = parameterTypes[i].getConstructor().newInstance(); }