From: Kai Moritz <kai@juplo.de>
Date: Sun, 5 Jan 2025 11:23:06 +0000 (+0100)
Subject: Zusätzliche Logging-Meldung für Retry-Ablauf
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=593ebc9385118442e2bf7188882b1a24d4a4acba;p=demos%2Fkafka%2Ftraining

Zusätzliche Logging-Meldung für Retry-Ablauf
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 7021fa04..8c1aff76 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -149,6 +149,11 @@ public class ExampleConsumer implements ConsumerRebalanceListener, Runnable
                 int partition = topicPartition.partition();
                 if (!backOffState[partition].isRetryInProgress(record.offset()))
                 {
+                  log.info(
+                    "{} - First occurrence of a retryable error for offset={} in partition {} - Initializing retry!",
+                    id,
+                    record.offset(),
+                    partition);
                   backOffState[partition] = new BackOffState(topicPartition, record.offset());
                   partitionHasRetryableError = true;
                   consumer.seek(topicPartition, record.offset());
@@ -166,6 +171,11 @@ public class ExampleConsumer implements ConsumerRebalanceListener, Runnable
                   }
                   else
                   {
+                    log.info(
+                      "{} - Retry in progress for offset={} in partition {}",
+                      id,
+                      record.offset(),
+                      partition);
                     consumer.seek(topicPartition, record.offset());
                     partitionHasRetryableError = true;
                     break;