Kafka: replace deprecated poll method millis param with Duration (tes…

…tcontainers#2318)
quincy · May 28, 2020 · f775161 · f775161
1 parent a8db4bb
commit f775161
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/modules/kafka/src/test/java/org/testcontainers/containers/KafkaContainerTest.java b/modules/kafka/src/test/java/org/testcontainers/containers/KafkaContainerTest.java
@@ -13,6 +13,7 @@
 import org.junit.Test;
 import org.rnorth.ducttape.unreliables.Unreliables;
 
+import java.time.Duration;
 import java.util.Arrays;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
@@ -100,7 +101,7 @@ protected void testKafkaFunctionality(String bootstrapServers) throws Exception
             producer.send(new ProducerRecord<>(topicName, "testcontainers", "rulezzz")).get();
 
             Unreliables.retryUntilTrue(10, TimeUnit.SECONDS, () -> {
-                ConsumerRecords<String, String> records = consumer.poll(100);
+                ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
 
                 if (records.isEmpty()) {
                     return false;