From 41607b763b50512e968a7444fed085907e94859a Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 5 Jan 2025 12:24:51 +0100 Subject: [PATCH] Nicht ausgewertete Unterscheidung entfernt --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index 72821382..89c75f13 100644 --- a/src/main/java/de/juplo/kafka/ExampleConsumer.java +++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java @@ -109,8 +109,6 @@ public class ExampleConsumer implements ConsumerRebalanceListener, Runnable recordsForPartition.size(), topicPartition); - boolean partitionHasRetryableError = false; - for (ConsumerRecord record : recordsForPartition) { if (abortCurrentPoll) @@ -155,7 +153,6 @@ public class ExampleConsumer implements ConsumerRebalanceListener, Runnable record.offset(), partition); backOffState[partition] = new BackOffState(topicPartition, record.offset()); - partitionHasRetryableError = true; consumer.seek(topicPartition, record.offset()); break; } @@ -177,7 +174,6 @@ public class ExampleConsumer implements ConsumerRebalanceListener, Runnable record.offset(), partition); consumer.seek(topicPartition, record.offset()); - partitionHasRetryableError = true; break; } } @@ -188,10 +184,7 @@ public class ExampleConsumer implements ConsumerRebalanceListener, Runnable log.warn("{} - Ignoring non-retryable error!", id, e); } - if (!partitionHasRetryableError) - { - backOffState[topicPartition.partition()].markRetryAsSuccessful(); - } + backOffState[topicPartition.partition()].markRetryAsSuccessful(); } } } -- 2.20.1