Package io.quarkus.kafka.streams.runtime

Class KafkaStreamsTopologyManager

java.lang.Object

io.quarkus.kafka.streams.runtime.KafkaStreamsTopologyManager

public class KafkaStreamsTopologyManager
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsTopologyManager(org.apache.kafka.clients.admin.Admin adminClient, org.apache.kafka.streams.Topology topology, KafkaStreamsRuntimeConfig runtimeConfig)

Method Summary

Modifier and Type	Method	Description
(package private) void	close()
static void	extractSources(org.apache.kafka.streams.Topology topo, Set<String> topics, Set<Pattern> patterns)
Set<String>	getMissingTopics()
List<Pattern>	getSourcePatterns()
List<String>	getSourceTopics()
boolean	isClosed()
boolean	isTopicsCheckEnabled()
void	waitForTopicsToBeCreated()

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaStreamsTopologyManager

public KafkaStreamsTopologyManager(org.apache.kafka.clients.admin.Admin adminClient,
 org.apache.kafka.streams.Topology topology,
 KafkaStreamsRuntimeConfig runtimeConfig)

Method Details

isTopicsCheckEnabled

public boolean isTopicsCheckEnabled()

close

void close()

isClosed

public boolean isClosed()

extractSources

public static void extractSources(org.apache.kafka.streams.Topology topo,
 Set<String> topics,
 Set<Pattern> patterns)

getSourceTopics

public List<String> getSourceTopics()

getSourcePatterns

public List<Pattern> getSourcePatterns()

getMissingTopics

public Set<String> getMissingTopics()
                             throws InterruptedException

Throws:

InterruptedException

waitForTopicsToBeCreated

public void waitForTopicsToBeCreated()
                              throws InterruptedException

Throws:

InterruptedException