From b3d62b62d1af885277483997973fb0c91e93673b Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 10 Jan 2025 17:34:56 +0100 Subject: [PATCH] GREEN - Fehler in der Initialisierung von `BackOffState` korrigiert --- src/main/java/de/juplo/kafka/BackOffState.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/de/juplo/kafka/BackOffState.java b/src/main/java/de/juplo/kafka/BackOffState.java index e06b8b74..37bef374 100644 --- a/src/main/java/de/juplo/kafka/BackOffState.java +++ b/src/main/java/de/juplo/kafka/BackOffState.java @@ -42,6 +42,7 @@ class BackOffState this.topicPartition = topicPartition; this.offset = offset; this.startTime = clock.instant(); + this.timeNextRetryIsDue = this.startTime; log.debug("{} - Back-Off requested for {} at {}", id, topicPartition, startTime); backOffExecution = backOffStrategy.start(); -- 2.20.1