1 package de.juplo.kafka;
3 import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
6 public interface PollIntervalAwareConsumerRebalanceListener extends ConsumerRebalanceListener
8 default void beforeNextPoll() {}
10 default void enableCommits() {}
11 default void disableCommits() {}