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

Modifier and Type	Method	Description
void	onPartitionsAssigned(Collection<LogPartition> partitions)
default void	onPartitionsLost(Collection<LogPartition> partitions)
void	onPartitionsRevoked(Collection<LogPartition> partitions)

Method Details

onPartitionsRevoked

void onPartitionsRevoked(Collection<LogPartition> partitions)

onPartitionsAssigned

void onPartitionsAssigned(Collection<LogPartition> partitions)

onPartitionsLost

default void onPartitionsLost(Collection<LogPartition> partitions)