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
.org.apache.kafka.streams.Topology
get()
Supplies a new Kafka StreamsTopology
instance.protected abstract org.apache.kafka.streams.StreamsBuilder
getStreamBuilder()
Returns theStreamsBuilder
which is used to build theTopology
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.
-
get
public org.apache.kafka.streams.Topology get()
Supplies a new Kafka StreamsTopology
instance.- Specified by:
get
in interfaceProvider<org.apache.kafka.streams.Topology>
- Specified by:
get
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.
-
-