From: Kai Moritz <kai@juplo.de>
Date: Fri, 2 Sep 2022 03:12:09 +0000 (+0200)
Subject: Falsch platzierte Methode aus RecordHandler entfernt
X-Git-Tag: sumup-adder--vorlage---lvm-2-tage~13
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=5c4b0d9c8e554fc497a6e7c1828081d64a46aa52;p=demos%2Fkafka%2Ftraining

Falsch platzierte Methode aus RecordHandler entfernt
---

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();
-  }
 }