org.apache.kafka.clients.admin

Class EvenClusterLoadPlanBrokerRelatedStats

java.lang.Object

org.apache.kafka.clients.admin.EvenClusterLoadPlanBrokerRelatedStats

public class EvenClusterLoadPlanBrokerRelatedStats
extends Object

Broker-related statistics class used in the construction of EvenClusterLoadPlan.

Constructor Summary

Constructors

Constructor and Description
EvenClusterLoadPlanBrokerRelatedStats(List<Integer> brokersExcludedForLeadership, List<Integer> brokersExcludedForReplicaMove, List<Integer> newBrokers, List<Integer> deadOrRemovedBrokers) Creates an EvenClusterLoadPlanBrokerRelatedStats object.

Method Summary

Modifier and Type	Method and Description
List<Integer>	brokersExcludedForLeadership() Brokers excluded for assigning replica leadership.
List<Integer>	brokersExcludedForReplicaMove() Brokers that cannot move replicas in or out of them.
List<Integer>	deadOrRemovedBrokers() Dead or removed brokers from the cluster.
List<Integer>	newBrokers() Brokers new to the cluster.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EvenClusterLoadPlanBrokerRelatedStats

public EvenClusterLoadPlanBrokerRelatedStats(List<Integer> brokersExcludedForLeadership,
                                             List<Integer> brokersExcludedForReplicaMove,
                                             List<Integer> newBrokers,
                                             List<Integer> deadOrRemovedBrokers)

Creates an EvenClusterLoadPlanBrokerRelatedStats object.

Parameters:

brokersExcludedForLeadership - brokers that cannot have replica leadership

brokersExcludedForReplicaMove - brokers excluded from replica movements to and from the broker

newBrokers - new brokers

deadOrRemovedBrokers - dead or removed brokers

Method Detail

brokersExcludedForLeadership

public List<Integer> brokersExcludedForLeadership()

Brokers excluded for assigning replica leadership.

Returns:

brokers excluded for leadership

brokersExcludedForReplicaMove

public List<Integer> brokersExcludedForReplicaMove()

Brokers that cannot move replicas in or out of them.

Returns:

brokers excluded for replica movements

newBrokers

public List<Integer> newBrokers()

Brokers new to the cluster.

Returns:

new brokers

deadOrRemovedBrokers

public List<Integer> deadOrRemovedBrokers()

Dead or removed brokers from the cluster.

Returns:

dead or removed brokers