Package io.streamthoughts.examples.azkarra.topology

Class ConfigurableWordCountTopology

java.lang.Object

io.streamthoughts.examples.azkarra.topology.ConfigurableWordCountTopology

All Implemented Interfaces:

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

@Component
@TopologyInfo(description="A configurable WordCount topology example")
public class ConfigurableWordCountTopology
extends Object
implements TopologyProvider, Configurable

A basic WordCount topology.

Constructor Summary

Constructors

Constructor	Description
ConfigurableWordCountTopology()

Method Summary

Modifier and Type	Method	Description
void	configure(Conf configuration)	Configures this instance with the specified Conf.
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

Constructor Detail

ConfigurableWordCountTopology

public ConfigurableWordCountTopology()

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.

configure

public void configure(Conf configuration)

Description copied from interface: Configurable

Configures this instance with the specified Conf.

Specified by:

configure in interface Configurable

Parameters:

configuration - the Conf instance used to configure this instance.

get

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

Description copied from interface: TopologyProvider

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.