From f7751618ef812949ef3773634c54ad15da3a095b Mon Sep 17 00:00:00 2001
From: nshipyakov <58605486+nshipyakov@users.noreply.github.com>
Date: Sun, 16 Feb 2020 23:48:23 +0300
Subject: [PATCH] Kafka: replace deprecated poll method millis param with
 Duration (#2318)

---
 .../java/org/testcontainers/containers/KafkaContainerTest.java | 3 ++-
 1 file changed, 2 insertions(+), 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
index add8b2b171d..1490caa3328 100644
--- 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;