Class OptimizedTopologyProvider
- java.lang.Object
-
- io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider
-
- All Implemented Interfaces:
Versioned
,Configurable
,Provider<org.apache.kafka.streams.Topology>
,TopologyProvider
public abstract class OptimizedTopologyProvider extends Object implements TopologyProvider, Configurable
ATopologyProvider
that can be used to build an optimizedTopology
instance.
-
-
Constructor Summary
Constructors Constructor Description OptimizedTopologyProvider()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected Conf
configuration()
ReturnsConf
defined for thisTopologyProvider
.void
configure(Conf configuration)
Configures this instance with the specifiedConf
.protected abstract org.apache.kafka.streams.StreamsBuilder
getStreamBuilder()
Returns theStreamsBuilder
which is used to build theTopology
instance.org.apache.kafka.streams.Topology
topology()
Supplies a new Kafka StreamsTopology
instance.-
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.streams.TopologyProvider
version
-
-
-
-
Method Detail
-
configure
public void configure(Conf configuration)
Configures this instance with the specifiedConf
.- Specified by:
configure
in interfaceConfigurable
- Parameters:
configuration
- theConf
instance used to configure this instance.
-
configuration
protected Conf configuration()
ReturnsConf
defined for thisTopologyProvider
.- Returns:
- a
Conf
instance.
-
topology
public org.apache.kafka.streams.Topology topology()
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.
-
getStreamBuilder
protected abstract org.apache.kafka.streams.StreamsBuilder getStreamBuilder()
Returns theStreamsBuilder
which is used to build theTopology
instance.- Returns:
- a
StreamsBuilder
instance.
-
-