Falsch platzierte Methode aus RecordHandler entfernt
authorKai Moritz <kai@juplo.de>
Fri, 2 Sep 2022 03:12:09 +0000 (05:12 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 2 Sep 2022 03:30:27 +0000 (05:30 +0200)
src/main/java/de/juplo/kafka/RecordHandler.java
src/test/java/de/juplo/kafka/ApplicationTests.java
src/test/java/de/juplo/kafka/TestRecordHandler.java

index 3c9dd15..327ac9f 100644 (file)
@@ -7,5 +7,4 @@ import java.util.function.Consumer;
 
 public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
 {
-  default void beforeNextPoll() {}
 }
index 4ff2a41..6a037eb 100644 (file)
@@ -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.*;
index de28385..b4efdd6 100644 (file)
@@ -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();
-  }
 }