From c1859ef2b4c2da556c337067f1e69b0950561a04 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 25 Sep 2024 22:34:29 +0200 Subject: [PATCH] Racecondition in Test korrigiert --- src/test/java/de/juplo/kafka/ApplicationTests.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java index 646a335..50bc20b 100644 --- a/src/test/java/de/juplo/kafka/ApplicationTests.java +++ b/src/test/java/de/juplo/kafka/ApplicationTests.java @@ -27,6 +27,7 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers. properties = { "spring.kafka.consumer.bootstrap-servers=${spring.embedded.kafka.brokers}", "producer.bootstrap-server=${spring.embedded.kafka.brokers}", + "spring.kafka.consumer.auto-offset-reset=earliest", "producer.topic=" + TOPIC}) @AutoConfigureMockMvc @EmbeddedKafka(topics = TOPIC, partitions = PARTITIONS) -- 2.20.1