Package org.nuxeo.lib.stream.log
Interface RebalanceListener
-
- All Known Implementing Classes:
ComputationRunner
,ConsumerRunner
public interface RebalanceListener
Listener to be notified on partition rebalancing.- Since:
- 9.3
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
onPartitionsAssigned(Collection<LogPartition> partitions)
default void
onPartitionsLost(Collection<LogPartition> partitions)
void
onPartitionsRevoked(Collection<LogPartition> partitions)
-
-
-
Method Detail
-
onPartitionsRevoked
void onPartitionsRevoked(Collection<LogPartition> partitions)
-
onPartitionsAssigned
void onPartitionsAssigned(Collection<LogPartition> partitions)
-
onPartitionsLost
default void onPartitionsLost(Collection<LogPartition> partitions)
-
-