From e209feea4d86bb6e4d901e1543f4bb3873807b79 Mon Sep 17 00:00:00 2001 From: Kai Moritz 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 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); -- 2.20.1