public interface BeginShutdownBrokerHandle
Modifier and Type | Method and Description |
---|---|
void |
beginShutdown(long brokerEpoch)
Start the shutdown process for this broker on the provided broker epoch.
|
long |
brokerEpoch()
The brokerEpoch corresponding to this broker.
|
long |
brokerId()
The brokerId corresponding to this broker.
|
Integer |
controllerId()
The brokerId of the current controller.
|
long |
underReplicatedPartitions()
The number of under replicated partitions on this broker.
|
long brokerId()
long brokerEpoch()
Integer controllerId()
long underReplicatedPartitions()
void beginShutdown(long brokerEpoch) throws org.apache.kafka.common.errors.StaleBrokerEpochException
org.apache.kafka.common.errors.StaleBrokerEpochException