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 bf237b7..ec874c4 100644 (file)
--- 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