[kafka] branch trunk updated: HOTFIX: remove deprecated calls

[gu...@apache.org]

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 <wa...@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."));