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