Class EvenClusterLoadPlanReplicaMovementStats

java.lang.Object

org.apache.kafka.clients.admin.EvenClusterLoadPlanReplicaMovementStats

public class EvenClusterLoadPlanReplicaMovementStats
extends Object

Replica movement statistics class used in the construction of EvenClusterLoadPlan.

Constructor Summary

Constructors

Constructor	Description
EvenClusterLoadPlanReplicaMovementStats(int interBrokerMoves, double interBrokerMovesMB, int leadershipMoves)	Creates an EvenClusterLoadPlanReplicaMovementStats object.

Method Summary

Modifier and Type	Method	Description
int	interBrokerMoves()	Number of replica movements between brokers.
double	interBrokerMovesMB()	Amount of replica movements between brokers in megabytes.
int	leadershipMoves()	Number of replica leadership moves.

Methods inherited from class java.lang.Object

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

Constructor Details

EvenClusterLoadPlanReplicaMovementStats

public EvenClusterLoadPlanReplicaMovementStats(int interBrokerMoves,
 double interBrokerMovesMB,
 int leadershipMoves)

Creates an EvenClusterLoadPlanReplicaMovementStats object.

Parameters:

interBrokerMoves - the number of reassignments moving replicas from one broker to another - e.g [1,2,3] => [1,2,4]

interBrokerMovesMB - the amount of data, in megabytes, to be moved from the inter-broker moves

leadershipMoves - the number of reassignments moving leadership from one broker to another - e.g [1,2,3] => [3,1,2]

Method Details

interBrokerMoves

public int interBrokerMoves()

Number of replica movements between brokers.

Returns:

inter-broker moves

interBrokerMovesMB

public double interBrokerMovesMB()

Amount of replica movements between brokers in megabytes.

Returns:

inter-broker moves in MB

leadershipMoves

public int leadershipMoves()

Number of replica leadership moves.

Returns:

leadership moves