From ebc7b6e835552982c667a08b17bb51c03e778725 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 11 Jan 2025 14:27:04 +0100
Subject: [PATCH] =?utf8?q?WIP:Bedingungsloser=20Reset=20(und=20besserer=20?=
=?utf8?q?Methoden-Name)=20f=C3=BCr=20`BackOffState`?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit
---
src/main/java/de/juplo/kafka/BackOffState.java | 3 ---
src/test/java/de/juplo/kafka/BackOffStateTest.java | 2 +-
2 files changed, 1 insertion(+), 4 deletions(-)
diff --git a/src/main/java/de/juplo/kafka/BackOffState.java b/src/main/java/de/juplo/kafka/BackOffState.java
index a51b5a9..5b41a1c 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 7160768..e77d23f 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);
--
2.20.1