From b02ae341d2f94419dfc9cb8aa84149e27fccbaff Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 22 Dec 2024 19:19:58 +0100 Subject: [PATCH] =?utf8?q?Keine=20Verz=C3=B6gerung=20f=C3=BCr=20Fehler=20i?= =?utf8?q?n=20den=20Retry-Tests?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/test/java/de/juplo/kafka/ExampleConsumerTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/test/java/de/juplo/kafka/ExampleConsumerTest.java b/src/test/java/de/juplo/kafka/ExampleConsumerTest.java index bf237b75..ec874c44 100644 --- a/src/test/java/de/juplo/kafka/ExampleConsumerTest.java +++ b/src/test/java/de/juplo/kafka/ExampleConsumerTest.java @@ -47,7 +47,7 @@ import static de.juplo.kafka.ExampleConsumerTest.*; "juplo.bootstrap-server=${spring.embedded.kafka.brokers}", "juplo.consumer.poll-request-timeout=" + POLL_REQUEST_TIMEOUT_MS + "ms", "juplo.consumer.max-poll-interval=" + MAX_POLL_INTERVALL_MS + "ms", - "juplo.consumer.max-time-per-record=" + ERROR_TIMEOUT_MS + "ms", + "juplo.consumer.max-time-per-record=" + MAX_TIME_PER_RECORD_MS + "ms", "juplo.consumer.num-retries=" + NUM_RETRIES, "spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.ByteArraySerializer", "logging.level.de.juplo.kafka=TRACE", @@ -340,7 +340,7 @@ public class ExampleConsumerTest static final int NUM_RETRIES = 6; static final int POLL_REQUEST_TIMEOUT_MS = 50; static final int MAX_POLL_INTERVALL_MS = 500; - static final int ERROR_TIMEOUT_MS = 100; + static final int MAX_TIME_PER_RECORD_MS = 100; @Autowired KafkaTemplate kafkaTemplate; @@ -380,7 +380,7 @@ public class ExampleConsumerTest @BeforeEach void resetParameters() { - mockRecordHandler.exceptionalRecordHandlingDelay = Duration.ofMillis(ERROR_TIMEOUT_MS); + mockRecordHandler.exceptionalRecordHandlingDelay = Duration.ofMillis(0); } @AfterEach -- 2.20.1