public class TopicManager
extends java.lang.Object
implements java.io.Closeable
Modifier and Type | Class and Description |
---|---|
static class |
TopicManager.Builder |
Constructor and Description |
---|
TopicManager(java.util.Properties clientProps,
java.util.Map<java.lang.String,java.lang.String> defaultTopicConfig,
java.lang.Integer defaultTopicPartitions,
java.lang.Integer defaultTopicReplicas,
java.lang.Integer timeOutMs,
java.util.Map<java.lang.String,TopicSpec> topics) |
Modifier and Type | Method and Description |
---|---|
void |
addTopic(TopicSpec spec) |
void |
close() |
java.util.concurrent.Future<java.lang.Boolean> |
ensureTopics() |
java.util.Set<java.lang.String> |
managedTopics() |
static TopicManager.Builder |
newBuilder() |
boolean |
reconcile() |
boolean |
topicExists(java.lang.String name) |
boolean |
topicManaged(java.lang.String name) |
public TopicManager(java.util.Properties clientProps, java.util.Map<java.lang.String,java.lang.String> defaultTopicConfig, java.lang.Integer defaultTopicPartitions, java.lang.Integer defaultTopicReplicas, java.lang.Integer timeOutMs, java.util.Map<java.lang.String,TopicSpec> topics)
public static TopicManager.Builder newBuilder()
public java.util.concurrent.Future<java.lang.Boolean> ensureTopics()
public boolean reconcile()
public void addTopic(TopicSpec spec)
public boolean topicExists(java.lang.String name)
public boolean topicManaged(java.lang.String name)
public java.util.Set<java.lang.String> managedTopics()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException