Package org.apache.kafka.clients.admin

Class EvenClusterLoadPlanReplicaMovementStats

java.lang.Object
org.apache.kafka.clients.admin.EvenClusterLoadPlanReplicaMovementStats
public class EvenClusterLoadPlanReplicaMovementStatsextends Object
Replica movement statistics class used in the construction of EvenClusterLoadPlan.

  • 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