Package org.apache.kafka.clients.admin
Class PartitionReassignment
- java.lang.Object
-
- org.apache.kafka.clients.admin.PartitionReassignment
-
public class PartitionReassignment extends java.lang.Object
A partition reassignment, which has been listed viaAdmin.listPartitionReassignments()
.
-
-
Constructor Summary
Constructors Constructor Description PartitionReassignment(java.util.List<java.lang.Integer> replicas, java.util.List<java.lang.Integer> addingReplicas, java.util.List<java.lang.Integer> removingReplicas)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<java.lang.Integer>
addingReplicas()
The brokers that we are adding this partition to as part of a reassignment.java.util.List<java.lang.Integer>
removingReplicas()
The brokers that we are removing this partition from as part of a reassignment.java.util.List<java.lang.Integer>
replicas()
The brokers which this partition currently resides on.java.lang.String
toString()
-
-
-
Method Detail
-
replicas
public java.util.List<java.lang.Integer> replicas()
The brokers which this partition currently resides on.
-
addingReplicas
public java.util.List<java.lang.Integer> addingReplicas()
The brokers that we are adding this partition to as part of a reassignment. A subset of replicas.
-
removingReplicas
public java.util.List<java.lang.Integer> removingReplicas()
The brokers that we are removing this partition from as part of a reassignment. A subset of replicas.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-