From: Kai Moritz <kai@juplo.de>
Date: Sun, 5 Jan 2025 11:24:51 +0000 (+0100)
Subject: Nicht ausgewertete Unterscheidung entfernt
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=59f4d04bca53e45ad212c1feacd47782ba8e6bef;p=demos%2Fkafka%2Ftraining

Nicht ausgewertete Unterscheidung entfernt
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 8c1aff76..c7208159 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<String, Long> 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();
             }
           }
         }