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