Class ServerSentEventExample.WordCountPublisherTopology
- java.lang.Object
-
- io.streamthoughts.azkarra.api.events.EventStreamSupport
-
- io.streamthoughts.examples.azkarra.sse.ServerSentEventExample.WordCountPublisherTopology
-
- All Implemented Interfaces:
Versioned
,EventStreamProvider
,Provider<org.apache.kafka.streams.Topology>
,TopologyProvider
- Enclosing class:
- ServerSentEventExample
@Component public static class ServerSentEventExample.WordCountPublisherTopology extends EventStreamSupport implements TopologyProvider
-
-
Constructor Summary
Constructors Constructor Description WordCountPublisherTopology()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.kafka.streams.Topology
topology()
Supplies a new Kafka StreamsTopology
instance.String
version()
Returns the version for thisTopology
.-
Methods inherited from class io.streamthoughts.azkarra.api.events.EventStreamSupport
addEventStream, addEventStreamsWithDefaults, eventStreams, send, send, send, send, setDefaultEventQueueLimitHandler, setDefaultEventQueueSize
-
-
-
-
Method Detail
-
version
public String version()
Description copied from interface:TopologyProvider
Returns the version for thisTopology
.- Specified by:
version
in interfaceTopologyProvider
- Specified by:
version
in interfaceVersioned
- Returns:
- the string version.
-
topology
public org.apache.kafka.streams.Topology topology()
Description copied from interface:TopologyProvider
Supplies a new Kafka StreamsTopology
instance.- Specified by:
topology
in interfaceProvider<org.apache.kafka.streams.Topology>
- Specified by:
topology
in interfaceTopologyProvider
- Returns:
- the
Topology
instance.
-
-