From d37524ef758607352b619b698f534807a2f6a232 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 2 Sep 2022 05:12:09 +0200
Subject: [PATCH] Falsch platzierte Methode aus RecordHandler entfernt

---
 src/main/java/de/juplo/kafka/RecordHandler.java     | 1 -
 src/test/java/de/juplo/kafka/ApplicationTests.java  | 1 -
 src/test/java/de/juplo/kafka/TestRecordHandler.java | 6 ------
 3 files changed, 8 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/RecordHandler.java b/src/main/java/de/juplo/kafka/RecordHandler.java
index 3c9dd15..327ac9f 100644
--- a/src/main/java/de/juplo/kafka/RecordHandler.java
+++ b/src/main/java/de/juplo/kafka/RecordHandler.java
@@ -7,5 +7,4 @@ import java.util.function.Consumer;
 
 public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
 {
-  default void beforeNextPoll() {}
 }
diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 4ff2a41..6a037eb 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -4,7 +4,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.apache.kafka.common.utils.Bytes;
-import org.assertj.core.api.Assertions;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import java.util.*;
diff --git a/src/test/java/de/juplo/kafka/TestRecordHandler.java b/src/test/java/de/juplo/kafka/TestRecordHandler.java
index de28385..b4efdd6 100644
--- a/src/test/java/de/juplo/kafka/TestRecordHandler.java
+++ b/src/test/java/de/juplo/kafka/TestRecordHandler.java
@@ -19,10 +19,4 @@ public abstract class TestRecordHandler<K, V> implements RecordHandler<K, V>
     this.onNewRecord(record);
     handler.accept(record);
   }
-  @Override
-
-  public void beforeNextPoll()
-  {
-    handler.beforeNextPoll();
-  }
 }
-- 
2.20.1