Die Implementierung speichert Zustand & Offsets vor _jedem_ `poll()`

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

package de.juplo.kafka;

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


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