juplo.de Git - demos/kafka/training/blob - src/main/java/de/juplo/kafka/RecordHandler.java

   1 package de.juplo.kafka;
   2
   3 import org.apache.kafka.clients.consumer.ConsumerRecord;
   4
   5 import java.util.function.Consumer;
   6
   7
   8 public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
   9 {
  10   default void beforeNextPoll() {}
  11 }