public interface BrokerLivenessListener
Modifier and Type | Method and Description |
---|---|
void |
notifyDeadBrokers(Set<Integer> deadBrokers)
Notify the component of the broker ids
deadBrokers consisting of brokers that just became offline. |
void |
notifyNewAddingBrokers(Set<Integer> newAddingBrokers)
Notify the component of the new broker ids
newAddingBrokers consisting of brokers with zero replicas
that just became online in the cluster and are going to have an addition operation performed on them. |
void |
notifyNewlyOnlineBrokers(Set<Integer> newlyOnlineBrokers)
Notify the component of the broker ids
newlyOnlineBrokers consisting of existing brokers with replicas on them that just became online in the cluster. |
void notifyNewAddingBrokers(Set<Integer> newAddingBrokers)
newAddingBrokers
consisting of brokers with zero replicas
that just became online in the cluster and are going to have an addition operation performed on them.void notifyNewlyOnlineBrokers(Set<Integer> newlyOnlineBrokers)
newlyOnlineBrokers
consisting of existing brokers with replicas on them that just became online in the cluster.
Note that this does NOT include the set of brokers notified as part of notifyNewAddingBrokers(Set)