public abstract class SbcAbstractBrokerAdditionEvent extends SbcInternalEvent
SbcEvent.SbcEventHandlerResult
eventContext, LOG
Constructor and Description |
---|
SbcAbstractBrokerAdditionEvent(SbcContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
notifyBrokerStartup(kafka.common.AliveBrokersMetadata aliveBrokersMetadata,
Set<Integer> emptyBrokers,
Set<Integer> newBrokers)
Notify SBC of the new brokers starting up
|
respondToClient
public SbcAbstractBrokerAdditionEvent(SbcContext context)
protected void notifyBrokerStartup(kafka.common.AliveBrokersMetadata aliveBrokersMetadata, Set<Integer> emptyBrokers, Set<Integer> newBrokers)
aliveBrokersMetadata
- - metadata related to the brokersemptyBrokers
- - the set of new brokers that are empty (have no replicas on them)newBrokers
- - the set of new brokers (superset of emptyBrokers)