-package de.juplo.kafka;
-
-import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
-
-
-public interface PollIntervalAwareConsumerRebalanceListener extends ConsumerRebalanceListener
-{
- default void beforeNextPoll() {}
-
- default void enableCommits() {}
- default void disableCommits() {}
-}