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 import org.apache.kafka.common.TopicPartition;
   5
   6 import java.util.function.Consumer;
   7
   8
   9 public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
  10 {
  11   default void beforeNextPoll() {}
  12
  13   default void onPartitionAssigned(TopicPartition tp) {}
  14
  15   default void onPartitionRevoked(TopicPartition tp) {}
  16 }