public class PartitionReassignment extends Object
Admin.listPartitionReassignments().| Constructor and Description |
|---|
PartitionReassignment(List<Integer> replicas, List<Integer> addingReplicas, List<Integer> removingReplicas) |
PartitionReassignment(List<Integer> replicas, List<Integer> observers, List<Integer> addingReplicas, List<Integer> removingReplicas) |
| Modifier and Type | Method and Description |
|---|---|
List<Integer> | addingReplicas()The brokers that we are adding this partition to as part of a reassignment. |
List<Integer> | observers()Get the replica observers which are asynchronously replicated. |
List<Integer> | removingReplicas()The brokers that we are removing this partition from as part of a reassignment. |
List<Integer> | replicas()The brokers which this partition currently resides on. |
String | toString() |
public PartitionReassignment(List<Integer> replicas, List<Integer> observers, List<Integer> addingReplicas, List<Integer> removingReplicas)
public List<Integer> observers()
replicas().public List<Integer> addingReplicas()
public List<Integer> removingReplicas()