Package io.streamthoughts.azkarra.api.streams.topology

Class TopologyContainer

java.lang.Object

io.streamthoughts.azkarra.api.streams.topology.TopologyContainer

public class TopologyContainer
extends Object

Default class to encapsulate a Topology instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopologyContainer.Builder

Method Summary

Modifier and Type	Method	Description
Tuple<Conf,org.apache.kafka.streams.KafkaStreams>	buildKafkaStreams(ApplicationId applicationId, Conf defaultStreamsConfig)	Builds a new KafkaStreams for this Topology.
TopologyMetadata	getMetadata()
org.apache.kafka.streams.Topology	getTopology()
static TopologyContainer.Builder	newBuilder()

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static TopologyContainer.Builder newBuilder()

getTopology

public org.apache.kafka.streams.Topology getTopology()

getMetadata

public TopologyMetadata getMetadata()

buildKafkaStreams

public Tuple<Conf,org.apache.kafka.streams.KafkaStreams> buildKafkaStreams(ApplicationId applicationId,
                                                                                 Conf defaultStreamsConfig)

Builds a new KafkaStreams for this Topology.

Parameters:

applicationId - the application id to be used.

defaultStreamsConfig - the default streamsConfig to be used.

Returns:

a new Tuple instance of a streams Conf instance and a KafkaStreams instance.