public class BrokerRemovalStateRecord
extends java.lang.Object
Constructor and Description |
---|
BrokerRemovalStateRecord(int brokerId,
BrokerRemovalStateMachine.BrokerRemovalState state,
java.lang.Exception exception) |
Modifier and Type | Method and Description |
---|---|
int |
brokerId() |
org.apache.kafka.clients.admin.BrokerShutdownStatus |
brokerShutdownStatus() |
boolean |
equals(java.lang.Object o) |
java.lang.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() |
java.lang.String |
toString() |
public BrokerRemovalStateRecord(int brokerId, BrokerRemovalStateMachine.BrokerRemovalState state, java.lang.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 java.lang.Exception exception()
public org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus()
public org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus()
public kafka.common.BrokerRemovalDescriptionInternal toRemovalDescription()
public java.lang.String toString()
toString
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object