1 package de.juplo.kafka;
3 import org.apache.kafka.clients.consumer.ConsumerRecord;
4 import org.apache.kafka.common.TopicPartition;
6 import java.util.function.Consumer;
9 public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
11 default void beforeNextPoll() {}
13 default void onPartitionAssigned(TopicPartition tp) {}
15 default void onPartitionRevoked(TopicPartition tp) {}