From: Kai Moritz <kai@juplo.de>
Date: Sun, 22 Dec 2024 18:19:58 +0000 (+0100)
Subject: Keine Verzögerung für Fehler in den Retry-Tests
X-Git-Tag: consumer/spring-consumer--error-handling--2025-02-signal~28
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=e7d8ccd84053f47a8b072e0ce4885c9d48aa3a0f;p=demos%2Fkafka%2Ftraining

Keine Verzögerung für Fehler in den Retry-Tests
---

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<String, byte[]> kafkaTemplate;
@@ -380,7 +380,7 @@ public class ExampleConsumerTest
   @BeforeEach
   void resetParameters()
   {
-    mockRecordHandler.exceptionalRecordHandlingDelay = Duration.ofMillis(ERROR_TIMEOUT_MS);
+    mockRecordHandler.exceptionalRecordHandlingDelay = Duration.ofMillis(0);
   }
 
   @AfterEach