org.apache.kafka.clients.admin

Class NewTopic

java.lang.Object

org.apache.kafka.clients.admin.NewTopic

public class NewTopic
extends Object

A new topic to be created via Admin.createTopics(Collection).

Constructor Summary

Constructors

Constructor and Description
NewTopic(String name, int numPartitions, short replicationFactor) A new topic with the specified replication factor and number of partitions.
NewTopic(String name, Map<Integer,List<Integer>> replicasAssignments) A new topic with the specified replica assignment configuration.
NewTopic(String name, Optional<Integer> numPartitions, Optional<Short> replicationFactor) A new topic that optionally defaults numPartitions and replicationFactor to the broker configurations for num.partitions and default.replication.factor respectively.

Method Summary

Modifier and Type	Method and Description
Map<String,String>	configs() The configuration for the new topic or null if no configs ever specified.
NewTopic	configs(Map<String,String> configs) Set the configuration to use on the new topic.
String	name() The name of the topic to be created.
int	numPartitions() The number of partitions for the new topic or -1 if a replica assignment has been specified.
Map<Integer,List<Integer>>	replicasAssignments() A map from partition id to replica ids (i.e.
short	replicationFactor() The replication factor for the new topic or -1 if a replica assignment has been specified.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NewTopic

public NewTopic(String name,
                int numPartitions,
                short replicationFactor)

A new topic with the specified replication factor and number of partitions.

NewTopic

public NewTopic(String name,
                Optional<Integer> numPartitions,
                Optional<Short> replicationFactor)

A new topic that optionally defaults numPartitions and replicationFactor to the broker configurations for num.partitions and default.replication.factor respectively.

NewTopic

public NewTopic(String name,
                Map<Integer,List<Integer>> replicasAssignments)

A new topic with the specified replica assignment configuration.

Parameters:

name - the topic name.

replicasAssignments - a map from partition id to replica ids (i.e. broker ids). Although not enforced, it is generally a good idea for all partitions to have the same number of replicas.

Method Detail

name

public String name()

The name of the topic to be created.

numPartitions

public int numPartitions()

The number of partitions for the new topic or -1 if a replica assignment has been specified.

replicationFactor

public short replicationFactor()

The replication factor for the new topic or -1 if a replica assignment has been specified.

replicasAssignments

public Map<Integer,List<Integer>> replicasAssignments()

A map from partition id to replica ids (i.e. broker ids) or null if the number of partitions and replication factor have been specified instead.

configs

public NewTopic configs(Map<String,String> configs)

Set the configuration to use on the new topic.

Parameters:

configs - The configuration map.

Returns:

This NewTopic object.

configs

public Map<String,String> configs()

The configuration for the new topic or null if no configs ever specified.

toString

public String toString()

Overrides:

toString in class Object