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