public class BrokerRemovalStateRecord extends Object
Constructor and Description |
---|
BrokerRemovalStateRecord(int brokerId,
BrokerRemovalStateMachine.BrokerRemovalState state,
Exception exception) |
Modifier and Type | Method and Description |
---|---|
int |
brokerId() |
org.apache.kafka.clients.admin.BrokerShutdownStatus |
brokerShutdownStatus() |
boolean |
equals(Object o) |
Exception |
exception() |
int |
hashCode() |
long |
lastUpdateTime() |
org.apache.kafka.clients.admin.PartitionReassignmentsStatus |
partitionReassignmentsStatus() |
void |
setLastUpdateTime(long lastUpdateTime) |
void |
setStartTime(long startTime) |
long |
startTime() |
BrokerRemovalStateMachine.BrokerRemovalState |
state() |
kafka.common.BrokerRemovalDescriptionInternal |
toRemovalDescription() |
String |
toString() |
public BrokerRemovalStateRecord(int brokerId, BrokerRemovalStateMachine.BrokerRemovalState state, Exception exception)
brokerId
- - the ID of the broker that is being removedstate
- - the latest state of the broker removal operationexception
- - nullable. the exception that caused the operation to enter this statepublic long startTime()
public void setStartTime(long startTime)
public long lastUpdateTime()
public void setLastUpdateTime(long lastUpdateTime)
public int brokerId()
public BrokerRemovalStateMachine.BrokerRemovalState state()
public Exception exception()
public org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus()
public org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus()
public kafka.common.BrokerRemovalDescriptionInternal toRemovalDescription()