Package io.streamthoughts.examples.azkarra.conditional

Class ConditionalStreamsApplication.NormalizeStreamsTopology

java.lang.Object

io.streamthoughts.azkarra.api.components.BaseComponentModule

io.streamthoughts.examples.azkarra.conditional.ConditionalStreamsApplication.NormalizeStreamsTopology

All Implemented Interfaces:

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

Enclosing class:

ConditionalStreamsApplication

@Component
@ConditionalOn(components=Normalize.class)
public static class ConditionalStreamsApplication.NormalizeStreamsTopology
extends BaseComponentModule
implements TopologyProvider

Constructor Summary

Constructors

Constructor	Description
NormalizeStreamsTopology()

Method Summary

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

Methods inherited from class io.streamthoughts.azkarra.api.components.BaseComponentModule

configure, getComponentFactory, getConfiguration, setComponentFactory

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory

getAllComponents, getAllComponents, getAllComponents, getAllComponents, getComponent, getComponent, getComponent, getComponent

Constructor Detail

NormalizeStreamsTopology

public NormalizeStreamsTopology()

Method Detail

version

public String version()

Description copied from interface: TopologyProvider

Returns the version for this Topology.

Specified by:

version in interface TopologyProvider

Specified by:

version in interface Versioned

Returns:

the string version.

topology

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

Description copied from interface: TopologyProvider

Supplies a new Kafka Streams Topology instance.

Specified by:

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

Specified by:

topology in interface TopologyProvider

Returns:

the Topology instance.