Log-Meldungen zu gespeichertem und wiederhergestelltem Zustand

[demos/kafka/training] / src / main / java / de / juplo / kafka / PollIntervalAwareConsumerRebalanceListener.java

package de.juplo.kafka;

import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;


public interface PollIntervalAwareConsumerRebalanceListener extends ConsumerRebalanceListener
{
  default void beforeNextPoll() {}
}