Class PartitionReassignment

java.lang.Object
org.apache.kafka.clients.admin.PartitionReassignment
public class PartitionReassignmentextends 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.

    • observers

      public List<Integer> observers()
      Get the replica observers which are asynchronously replicated. These are a subset of replicas().

    • 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