org.apache.kafka.clients.admin

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 and Description
NewPartitionReassignment(List<Integer> targetReplicas)

Method Summary

Modifier and Type	Method and 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 Detail

NewPartitionReassignment

public NewPartitionReassignment(List<Integer> targetReplicas)

Throws:

IllegalArgumentException - if no replicas are supplied

Method Detail

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()