From 29a40042cf2c310050b8aaa752f13b76c9c2c2a1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mich=C3=A8le=20BARRE?= Date: Tue, 21 Mar 2023 13:06:30 +1100 Subject: [PATCH] test(upgrade): kafka, sb --- src/test/java/nc/opt/springkafka/KafkaServiceTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/test/java/nc/opt/springkafka/KafkaServiceTest.java b/src/test/java/nc/opt/springkafka/KafkaServiceTest.java index ae66585..a49196f 100644 --- a/src/test/java/nc/opt/springkafka/KafkaServiceTest.java +++ b/src/test/java/nc/opt/springkafka/KafkaServiceTest.java @@ -1,13 +1,13 @@ package nc.opt.springkafka; -import nc.opt.springkafka.service.KafkaService; import nc.opt.springkafka.dto.MessageDTO; +import nc.opt.springkafka.service.KafkaService; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.common.serialization.StringDeserializer; +import org.junit.Assert; import org.junit.jupiter.api.Test; -import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration; @@ -18,9 +18,9 @@ import org.springframework.kafka.test.context.EmbeddedKafka; import org.springframework.kafka.test.utils.KafkaTestUtils; import org.springframework.test.annotation.DirtiesContext; -import org.springframework.test.context.junit4.SpringRunner; -import org.junit.Assert; +import java.time.Duration; +import java.time.temporal.ChronoUnit; import java.util.Map; import static org.hamcrest.MatcherAssert.assertThat; @@ -64,7 +64,7 @@ public void push() { String key = result.getProducerRecord().key(); embeddedKafka.consumeFromEmbeddedTopics(consumer, messageTopic); - final ConsumerRecord record = getSingleRecord(consumer, messageTopic, 10_000); + final ConsumerRecord record = getSingleRecord(consumer, messageTopic, Duration.of(10_000, ChronoUnit.MILLIS)); assertThat(record, hasValue(value)); assertThat(record, hasKey(key));