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) {}
}