public class BrokerRemovalDescriptionInternal extends Object
Constructor and Description |
---|
BrokerRemovalDescriptionInternal(int brokerId,
org.apache.kafka.clients.admin.BalancerOperationStatus generalOperationStatus,
org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus replicaExclusionStatus,
org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus,
org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus,
Exception e,
long createTimeMs,
long lastUpdateTimeMs,
boolean shutdownScheduled) |
Modifier and Type | Method and Description |
---|---|
int |
brokerId() |
org.apache.kafka.clients.admin.BrokerShutdownStatus |
brokerShutdownStatus() |
long |
createTimeMs() |
boolean |
equals(Object o) |
Exception |
exception()
The nullable #
Exception that this broker removal operation experienced |
org.apache.kafka.clients.admin.BalancerOperationStatus |
generalOperationStatus() |
int |
hashCode() |
long |
lastUpdateTimeMs() |
org.apache.kafka.clients.admin.PartitionReassignmentsStatus |
partitionReassignmentsStatus() |
org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus |
replicaExclusionStatus() |
boolean |
shutdownScheduled()
Denotes whether this broker removal operation had the shutdown broker step enabled to run.
|
String |
toString() |
public BrokerRemovalDescriptionInternal(int brokerId, org.apache.kafka.clients.admin.BalancerOperationStatus generalOperationStatus, org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus replicaExclusionStatus, org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus, org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus, Exception e, long createTimeMs, long lastUpdateTimeMs, boolean shutdownScheduled)
public int brokerId()
public long createTimeMs()
public long lastUpdateTimeMs()
public Exception exception()
Exception
that this broker removal operation experiencedpublic boolean shutdownScheduled()
public org.apache.kafka.clients.admin.BalancerOperationStatus generalOperationStatus()
public org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentsStatus()
public org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus()
public org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus replicaExclusionStatus()