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 a51b5a9..5b41a1c 100644 (file)
--- 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 7160768..e77d23f 100644 (file)
--- 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);