org.apache.kafka.clients.admin

Class NewPartitions

java.lang.Object

org.apache.kafka.clients.admin.NewPartitions

@InterfaceStability.Evolving
public class NewPartitions
extends Object

Describes new partitions for a particular topic in a call to Admin.createPartitions(Map). The API of this class is evolving, see Admin for details.

Method Summary

Modifier and Type	Method and Description
List<List<Integer>>	assignments() The replica assignments for the new partitions, or null if the assignment will be done by the controller.
static NewPartitions	increaseTo(int totalCount) Increase the partition count for a topic to the given totalCount.
static NewPartitions	increaseTo(int totalCount, List<List<Integer>> newAssignments) Increase the partition count for a topic to the given totalCount assigning the new partitions according to the given newAssignments.
String	toString()
int	totalCount() The total number of partitions after the operation succeeds.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

increaseTo

public static NewPartitions increaseTo(int totalCount)

Increase the partition count for a topic to the given totalCount. The assignment of new replicas to brokers will be decided by the broker.

Parameters:

totalCount - The total number of partitions after the operation succeeds.

increaseTo

public static NewPartitions increaseTo(int totalCount,
                                       List<List<Integer>> newAssignments)

Increase the partition count for a topic to the given totalCount assigning the new partitions according to the given newAssignments. The length of the given newAssignments should equal totalCount - oldCount, since the assignment of existing partitions are not changed. Each inner list of newAssignments should have a length equal to the topic's replication factor. The first broker id in each inner list is the "preferred replica".

For example, suppose a topic currently has a replication factor of 2, and has 3 partitions. The number of partitions can be increased to 6 using a NewPartition constructed like this:

 NewPartitions.increaseTo(6, asList(asList(1, 2),
                                    asList(2, 3),
                                    asList(3, 1)))
 

In this example partition 3's preferred leader will be broker 1, partition 4's preferred leader will be broker 2 and partition 5's preferred leader will be broker 3.

Parameters:

totalCount - The total number of partitions after the operation succeeds.

newAssignments - The replica assignments for the new partitions.

totalCount

public int totalCount()

The total number of partitions after the operation succeeds.

assignments

public List<List<Integer>> assignments()

The replica assignments for the new partitions, or null if the assignment will be done by the controller.

toString

public String toString()

Overrides:

toString in class Object