Class PartitionReassignment

java.lang.Object
org.apache.kafka.clients.admin.PartitionReassignment

public class PartitionReassignment
extends Object
A partition reassignment, which has been listed via Admin.listPartitionReassignments().
  • Constructor Details

  • Method Details

    • replicas

      public List<Integer> replicas()
      The brokers which this partition currently resides on.
    • addingReplicas

      public List<Integer> addingReplicas()
      The brokers that we are adding this partition to as part of a reassignment. A subset of replicas.
    • removingReplicas

      public List<Integer> removingReplicas()
      The brokers that we are removing this partition from as part of a reassignment. A subset of replicas.
    • toString

      public String toString()
      Overrides:
      toString in class Object