public static final class TopicManager.Builder
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
TopicManager |
build() |
TopicManager.Builder |
setAdminClientProperties(java.util.Properties adminClientProperties) |
TopicManager.Builder |
setDefaultTopicConfig(java.util.Map<java.lang.String,java.lang.String> defaultTopicConfig) |
TopicManager.Builder |
setDefaultTopicPartitions(java.lang.Integer defaultTopicPartitions) |
TopicManager.Builder |
setDefaultTopicReplicas(java.lang.Integer defaultTopicReplicas) |
TopicManager.Builder |
setTimeOutMs(java.lang.Integer timeOutMs) |
TopicManager.Builder |
setTopics(java.util.Map<java.lang.String,TopicSpec> topics) |
public TopicManager.Builder setDefaultTopicPartitions(java.lang.Integer defaultTopicPartitions)
public TopicManager.Builder setDefaultTopicReplicas(java.lang.Integer defaultTopicReplicas)
public TopicManager.Builder setAdminClientProperties(java.util.Properties adminClientProperties)
public TopicManager.Builder setDefaultTopicConfig(java.util.Map<java.lang.String,java.lang.String> defaultTopicConfig)
public TopicManager.Builder setTimeOutMs(java.lang.Integer timeOutMs)
public TopicManager.Builder setTopics(java.util.Map<java.lang.String,TopicSpec> topics)
public TopicManager build()