org.springframework.kafka.config

Class TopicBuilder

java.lang.Object

org.springframework.kafka.config.TopicBuilder

public final class TopicBuilder
extends java.lang.Object

Builder for a NewTopic.

Since:

2.3

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.admin.NewTopic	build()
TopicBuilder	compact() Set the TopicConfig.CLEANUP_POLICY_CONFIG to TopicConfig.CLEANUP_POLICY_COMPACT.
TopicBuilder	config(java.lang.String configName, java.lang.String configValue) Set a configuration option.
TopicBuilder	configs(java.util.Map<java.lang.String,java.lang.String> configs) Set the configs.
static TopicBuilder	name(java.lang.String name) Create a TopicBuilder with the supplied name.
TopicBuilder	partitions(int partitions) Set the number of partitions (default 1).
TopicBuilder	replicas(int replicas) Set the number of replicas (default 1).
TopicBuilder	replicasAssignments(java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> replicasAssignments) Set the replica assignments.

Methods inherited from class java.lang.Object

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

Method Detail

partitions

public TopicBuilder partitions(int partitions)

Set the number of partitions (default 1).

Parameters:

partitions - the partitions.

Returns:

the builder.

replicas

public TopicBuilder replicas(int replicas)

Set the number of replicas (default 1).

Parameters:

replicas - the replicas (which will be cast to short).

Returns:

the builder.

replicasAssignments

public TopicBuilder replicasAssignments(java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> replicasAssignments)

Set the replica assignments.

Parameters:

replicasAssignments - the assignments.

Returns:

the builder.

See Also:

NewTopic.replicasAssignments()

configs

public TopicBuilder configs(java.util.Map<java.lang.String,java.lang.String> configs)

Set the configs.

Parameters:

configs - the configs.

Returns:

the builder.

See Also:

NewTopic.configs()

config

public TopicBuilder config(java.lang.String configName,
                           java.lang.String configValue)

Set a configuration option.

Parameters:

configName - the name.

configValue - the value.

Returns:

the builder

See Also:

TopicConfig

compact

public TopicBuilder compact()

Set the TopicConfig.CLEANUP_POLICY_CONFIG to TopicConfig.CLEANUP_POLICY_COMPACT.

Returns:

the builder.

build

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

name

public static TopicBuilder name(java.lang.String name)

Create a TopicBuilder with the supplied name.

Parameters:

name - the name.

Returns:

the builder.