Package io.confluent.security.audit.telemetry.exporter

Class TopicManager

java.lang.Object

io.confluent.security.audit.telemetry.exporter.TopicManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class TopicManager
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TopicManager.Builder

Constructor Summary

Constructors

Constructor	Description
TopicManager(Properties clientProps, Map<String,String> defaultTopicConfig, Integer defaultTopicPartitions, Integer defaultTopicReplicas, Integer timeOutMs, Map<String,TopicSpec> topics)

Method Summary

Modifier and Type	Method	Description
void	addTopic(TopicSpec spec)
final boolean	check()
final 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)

Methods inherited from class java.lang.Object

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

Constructor Details

TopicManager

public TopicManager(Properties clientProps,
 Map<String,String> defaultTopicConfig,
 Integer defaultTopicPartitions,
 Integer defaultTopicReplicas,
 Integer timeOutMs,
 Map<String,TopicSpec> topics)

Method Details

newBuilder

public static TopicManager.Builder newBuilder()

ensureTopics

public Future<Boolean> ensureTopics()

checkTopics

public final Future<Boolean> checkTopics()

check

public final boolean check()

reconcile

public boolean reconcile()

addTopic

public void addTopic(TopicSpec spec)

topicExists

public boolean topicExists(String name)

topicManaged

public boolean topicManaged(String name)

managedTopics

public Set<String> managedTopics()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable