public class BrokerRemovalStateRecord extends Object
Constructor and Description |
---|
BrokerRemovalStateRecord(Set<Integer> brokerIds,
BrokerRemovalStateMachine.BrokerRemovalState state,
Exception exception,
boolean shouldShutdown) |
Modifier and Type | Method and Description |
---|---|
ImmutableSet<Integer> |
brokerIds() |
org.apache.kafka.clients.admin.BrokerShutdownStatus |
brokerShutdownStatus() |
boolean |
equals(Object o) |
Exception |
exception() |
int |
hashCode() |
long |
lastUpdateTime() |
org.apache.kafka.clients.admin.PartitionReassignmentsStatus |
partitionReassignmentsStatus() |
org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus |
replicaExclusionStatus() |
void |
setLastUpdateTime(long lastUpdateTime) |
void |
setStartTime(long startTime) |
boolean |
shouldShutdown() |
long |
startTime() |
BrokerRemovalStateMachine.BrokerRemovalState |
state() |
List<kafka.common.BrokerRemovalDescriptionInternal> |
toRemovalDescriptions()
Return a
BrokerRemovalDescriptionInternal for each broker that's being
removed in the removal operation that this record represents. |
String |
toString() |
public BrokerRemovalStateRecord(Set<Integer> brokerIds, BrokerRemovalStateMachine.BrokerRemovalState state, Exception exception, boolean shouldShutdown)
brokerIds
- - the set of broker IDs being removedstate
- - the latest state of the broker removal operationexception
- - nullable. the exception that caused the operation to enter this stateshouldShutdown
- - denotes whether this removal operation had its shutdown step enabledpublic long startTime()
public void setStartTime(long startTime)
public long lastUpdateTime()
public void setLastUpdateTime(long lastUpdateTime)
public ImmutableSet<Integer> brokerIds()
public BrokerRemovalStateMachine.BrokerRemovalState state()
public Exception exception()
public org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus()
public org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus()
public org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus replicaExclusionStatus()
public boolean shouldShutdown()
public List<kafka.common.BrokerRemovalDescriptionInternal> toRemovalDescriptions()
BrokerRemovalDescriptionInternal
for each broker that's being
removed in the removal operation that this record represents.
Because the DescribeBrokerRemovals Admin API still exposes the operation's state per broker id,
we return one description per broker to later get mapped onto the user-facing description.