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