Package io.streamthoughts.examples.azkarra.topology

Class BasicWordCountTopology

java.lang.Object

io.streamthoughts.examples.azkarra.topology.BasicWordCountTopology

All Implemented Interfaces:

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

@Component
@TopologyInfo(description="A basic WordCount topology example",
              aliases="Word")
public class BasicWordCountTopology
extends Object
implements TopologyProvider

A basic WordCount topology.

Constructor Summary

Constructors

Constructor	Description
BasicWordCountTopology()

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

Constructor Detail

BasicWordCountTopology

public BasicWordCountTopology()

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.

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.