From 06500958d9efa4145046fd61f10c3614f4b14a4a Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 5 Jan 2025 12:23:06 +0100 Subject: [PATCH] =?utf8?q?Zus=C3=A4tzliche=20Logging-Meldung=20f=C3=BCr=20?= =?utf8?q?Retry-Ablauf?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index 7f9b2c6e..72821382 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; -- 2.20.1