Class NewPartitionReassignment

java.lang.Object

org.apache.kafka.clients.admin.NewPartitionReassignment

public class NewPartitionReassignment
extends Object

A new partition reassignment, which can be applied via Admin.alterPartitionReassignments(Map, AlterPartitionReassignmentsOptions). targetReplicas is the total set of brokers assigned while targetObservers is the set brokers that will act as observers. The size of targetReplicas must be greater than the size of targetObservers and every targetObservers must be included in targetReplicas.

Constructor Summary

Constructors

Constructor	Description
NewPartitionReassignment(List<Integer> targetReplicas)

Method Summary

Modifier and Type	Method	Description
static NewPartitionReassignment	ofReplicasAndObservers(List<Integer> replicas, List<Integer> observers)
List<Integer>	targetObservers()
List<Integer>	targetReplicas()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NewPartitionReassignment

public NewPartitionReassignment(List<Integer> targetReplicas)

Throws:

IllegalArgumentException - if no replicas are supplied

Method Details

ofReplicasAndObservers

@Confluent
public static NewPartitionReassignment ofReplicasAndObservers(List<Integer> replicas,
 List<Integer> observers)

Throws:

IllegalArgumentException - if no replicas are supplied or observers is null

targetReplicas

public List<Integer> targetReplicas()

targetObservers

@Confluent
public List<Integer> targetObservers()