This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new 23ed45a HOTFIX: remove deprecated calls 23ed45a is described below commit 23ed45a21df3717332cbd2e284e9867ef5c2cc51 Author: Guozhang Wang <wangg...@gmail.com> AuthorDate: Thu Nov 15 14:28:13 2018 -0800 HOTFIX: remove deprecated calls --- .../apache/kafka/streams/processor/internals/ProcessorContextTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java index 1523995..e652ee5 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java @@ -59,7 +59,7 @@ public class ProcessorContextTest { @Test public void shouldNotAllowToScheduleZeroMillisecondPunctuation() { try { - context.schedule(0, null, null); + context.schedule(Duration.ofMillis(0L), null, null); fail("Should have thrown IllegalArgumentException"); } catch (final IllegalArgumentException expected) { assertThat(expected.getMessage(), equalTo("The minimum supported scheduling interval is 1 millisecond."));