quarkusio#2691 Removing call to deprecated method

gunnarmorling · Jun 3, 2019 · 22084a2 · 22084a2
1 parent 1f5a422
commit 22084a2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/integration-tests/kafka/src/main/java/io/quarkus/it/kafka/KafkaConsumerManager.java b/integration-tests/kafka/src/main/java/io/quarkus/it/kafka/KafkaConsumerManager.java
@@ -1,5 +1,6 @@
 package io.quarkus.it.kafka;
 
+import java.time.Duration;
 import java.util.Collections;
 import java.util.Properties;
 
@@ -28,7 +29,6 @@ public static KafkaConsumer<Integer, String> createConsumer() {
         return consumer;
     }
 
-    private int count;
     private Consumer<Integer, String> consumer;
 
     @PostConstruct
@@ -37,7 +37,7 @@ public void create() {
     }
 
     public String receive() {
-        return consumer.poll(10000).iterator().next().value();
+        return consumer.poll(Duration.ofMillis(10000)).iterator().next().value();
     }
 
 }
diff --git a/integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaProducerTest.java b/integration-tests/kafka/src/test/java/io/quarkus/it/main/KafkaProducerTest.java
@@ -1,5 +1,6 @@
 package io.quarkus.it.main;
 
+import java.time.Duration;
 import java.util.Collections;
 import java.util.Properties;
 
@@ -34,7 +35,7 @@ public static KafkaConsumer<Integer, String> createConsumer() {
     public void test() throws Exception {
         KafkaConsumer<Integer, String> consumer = createConsumer();
         RestAssured.with().body("hello").post("/kafka");
-        ConsumerRecord<Integer, String> records = consumer.poll(10000).iterator().next();
+        ConsumerRecord<Integer, String> records = consumer.poll(Duration.ofMillis(10000)).iterator().next();
         Assertions.assertEquals(records.key(), (Integer) 0);
         Assertions.assertEquals(records.value(), "hello");
     }