Package io.streamthoughts.azkarra.runtime.context.internal

Class ContextAwareTopologySupplier.DelegateContextTopologyProvider

java.lang.Object

io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier.DelegateContextTopologyProvider

All Implemented Interfaces:

Versioned, Provider<org.apache.kafka.streams.Topology>, TopologyProvider

Enclosing class:

ContextAwareTopologySupplier

public static class ContextAwareTopologySupplier.DelegateContextTopologyProvider
extends Object
implements TopologyProvider

A delegating TopologyProvider which is not Configurable.

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.streams.Topology	get()	Supplies a new Kafka Streams Topology instance.
String	version()	Returns the version for this Topology.

Methods inherited from class java.lang.Object

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

Method Detail

version

public String version()

Returns the version for this Topology.

Specified by:

version in interface TopologyProvider

Specified by:

version in interface Versioned

Returns:

the string version.

get

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

Supplies a new Kafka Streams Topology instance.

Specified by:

get in interface Provider<org.apache.kafka.streams.Topology>

Specified by:

get in interface TopologyProvider

Returns:

the Topology instance.