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 7021fa0..8c1aff7 100644 (file)
--- 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;