io.confluent.license.util

Class LicenseTopicAdmin.NewTopicBuilder

java.lang.Object

io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder

Enclosing class:

LicenseTopicAdmin

public static class LicenseTopicAdmin.NewTopicBuilder
extends Object

A builder of NewTopic instances.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.admin.NewTopic	build() Build the NewTopic representation.
LicenseTopicAdmin.NewTopicBuilder	compacted() Specify that the topic should be compacted.
LicenseTopicAdmin.NewTopicBuilder	config(Map<String,Object> configs) Specify the configuration properties for the topic, overwriting any previously-set properties.
LicenseTopicAdmin.NewTopicBuilder	defaultPartitions() Specify the topic's number of partition should be the broker configuration for num.partitions.
LicenseTopicAdmin.NewTopicBuilder	defaultReplicationFactor() Specify the replication factor for the topic should be the broker configurations for default.replication.factor.
LicenseTopicAdmin.NewTopicBuilder	minInSyncReplicas(short minInSyncReplicas) Specify the minimum number of in-sync replicas required for this topic.
LicenseTopicAdmin.NewTopicBuilder	partitions(int numPartitions) Specify the desired number of partitions for the topic.
LicenseTopicAdmin.NewTopicBuilder	replicationFactor(short replicationFactor) Specify the desired replication factor for the topic.

Methods inherited from class java.lang.Object

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

Method Detail

partitions

public LicenseTopicAdmin.NewTopicBuilder partitions(int numPartitions)

Specify the desired number of partitions for the topic.

Parameters:

numPartitions - the desired number of partitions; must be positive, or -1 to signify using the broker's default

Returns:

this builder to allow methods to be chained; never null

defaultPartitions

public LicenseTopicAdmin.NewTopicBuilder defaultPartitions()

Specify the topic's number of partition should be the broker configuration for num.partitions.

Returns:

this builder to allow methods to be chained; never null

replicationFactor

public LicenseTopicAdmin.NewTopicBuilder replicationFactor(short replicationFactor)

Specify the desired replication factor for the topic.

Parameters:

replicationFactor - the desired replication factor; must be positive, or -1 to signify using the broker's default

Returns:

this builder to allow methods to be chained; never null

defaultReplicationFactor

public LicenseTopicAdmin.NewTopicBuilder defaultReplicationFactor()

Specify the replication factor for the topic should be the broker configurations for default.replication.factor.

Returns:

this builder to allow methods to be chained; never null

compacted

public LicenseTopicAdmin.NewTopicBuilder compacted()

Specify that the topic should be compacted.

Returns:

this builder to allow methods to be chained; never null

minInSyncReplicas

public LicenseTopicAdmin.NewTopicBuilder minInSyncReplicas(short minInSyncReplicas)

Specify the minimum number of in-sync replicas required for this topic.

Parameters:

minInSyncReplicas - the minimum number of in-sync replicas allowed for the topic; must be positive

Returns:

this builder to allow methods to be chained; never null

config

public LicenseTopicAdmin.NewTopicBuilder config(Map<String,Object> configs)

Specify the configuration properties for the topic, overwriting any previously-set properties.

Parameters:

configs - the desired topic configuration properties, or null if all existing properties should be cleared

Returns:

this builder to allow methods to be chained; never null

build

public org.apache.kafka.clients.admin.NewTopic build()

Build the NewTopic representation.

Returns:

the topic description; never null