From: Kai Moritz <kai@juplo.de>
Date: Sat, 11 Jan 2025 13:27:04 +0000 (+0100)
Subject: WIP:Bedingungsloser Reset (und besserer Methoden-Name) für `BackOffState`
X-Git-Tag: consumer/spring-consumer--error-handling--2025-02-signal~2
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=e209feea4d86bb6e4d901e1543f4bb3873807b79;p=demos%2Fkafka%2Ftraining

WIP:Bedingungsloser Reset (und besserer Methoden-Name) für `BackOffState`
---

diff --git a/src/main/java/de/juplo/kafka/BackOffState.java b/src/main/java/de/juplo/kafka/BackOffState.java
index a51b5a98..5b41a1c7 100644
--- a/src/main/java/de/juplo/kafka/BackOffState.java
+++ b/src/main/java/de/juplo/kafka/BackOffState.java
@@ -19,7 +19,6 @@ class BackOffState
   private final TopicPartition topicPartition;
   @Getter
   private final long offset;
-  private final Instant startTime;
 
   private BackOffExecution backOffExecution;
   private int numRetries = 0;
@@ -32,7 +31,6 @@ class BackOffState
     clock = null;
     topicPartition = null;
     offset = -1;
-    startTime = null;
   }
 
   BackOffState(String id, BackOff backOffStrategy, Clock clock, TopicPartition topicPartition, long offset)
@@ -41,7 +39,6 @@ class BackOffState
     this.clock = clock;
     this.topicPartition = topicPartition;
     this.offset = offset;
-    this.startTime = clock.instant();
 
     log.info(
       "{} - Back-Off requested for offset={} in {}",
diff --git a/src/test/java/de/juplo/kafka/BackOffStateTest.java b/src/test/java/de/juplo/kafka/BackOffStateTest.java
index 7160768d..e77d23f4 100644
--- a/src/test/java/de/juplo/kafka/BackOffStateTest.java
+++ b/src/test/java/de/juplo/kafka/BackOffStateTest.java
@@ -65,7 +65,7 @@ class BackOffStateTest
 
   private BackOffState StartedBackoffStateWithNoRetries()
   {
-    given(clock.instant()).willReturn(NOW);
+    // GIVEN
     given(backOff.start()).willReturn(backOffExecution);
     given(backOffExecution.nextBackOff()).willReturn(BackOffExecution.STOP);