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