Package org.apache.kafka.clients.admin
Class BalancerStatusDescription
java.lang.Object
org.apache.kafka.clients.admin.BalancerStatusDescription
A description of the balancer status which is fetched via
ConfluentAdmin.describeBalancerStatus(DescribeBalancerStatusOptions). The status of the balancer is tracked by a status field: #balancerStatus(). * IDs of the brokers where Confluent Balancer is running is stored in field #brokerIds(). In addition to the status field, the #balancerOperationError() gives context about the status of the balancer, e.g. why the balancer is in an error state etc.Constructor Summary
ConstructorsConstructorDescriptionBalancerStatusDescription(BalancerStatus balancerStatus, Collection<Integer> brokerIds, BalancerOperationError balancerOperationError) Method Summary
Modifier and TypeMethodDescriptionAn optional error that gives context as to why the balancer is in the given state.The current status of the Confluent Balancer component.IDs of the brokers where Confluent Balancer component is running.toString()
Constructor Details
BalancerStatusDescription
public BalancerStatusDescription(BalancerStatus balancerStatus, Collection<Integer> brokerIds, BalancerOperationError balancerOperationError)
Method Details
balancerStatus
The current status of the Confluent Balancer component.- See Also:
brokerIds
IDs of the brokers where Confluent Balancer component is running.- Returns:
- a set of unique broker ids
balancerOperationError
An optional error that gives context as to why the balancer is in the given state.toString