From bb335a54a1c4eafa5458b7bbe3bd7865ec320ba2 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 10 Jan 2025 15:03:49 +0100
Subject: [PATCH] Logging in `BackOffState` verbessert

---
 src/main/java/de/juplo/kafka/BackOffState.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/BackOffState.java b/src/main/java/de/juplo/kafka/BackOffState.java
index 92d08df0..b656b10c 100644
--- a/src/main/java/de/juplo/kafka/BackOffState.java
+++ b/src/main/java/de/juplo/kafka/BackOffState.java
@@ -55,16 +55,18 @@ class BackOffState
       return false;
     }
 
-    if (clock.instant().isAfter(timeNextRetryIsDue))
+    Instant now = clock.instant();
+    Duration remaining = Duration.between(now, timeNextRetryIsDue);
+    if (remaining.isNegative())
     {
       numRetries++;
+      log.info("{} - {}. retry for {}, lateness: {}", id, numRetries, topicPartition, remaining.abs());
       initializeNextBackOff();
-      log.info("{} - Retrying {}", id, topicPartition);
       return false;
     }
     else
     {
-      log.info("{} - Next retry for {} is due at {}", id, topicPartition, timeNextRetryIsDue);
+      log.info("{} - Next retry for {} is due in {}", id, topicPartition, remaining);
       return true;
     }
   }
-- 
2.20.1