Class ConfiguredStreamBuilder
java.lang.Object
org.apache.kafka.streams.StreamsBuilder
io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder
Extended version of
StreamsBuilder
that can be configured.- Since:
- 1.0
- Author:
- graemerocher
-
Field Summary
Fields inherited from class org.apache.kafka.streams.StreamsBuilder
internalStreamsBuilder, internalTopologyBuilder, topology
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.apache.kafka.streams.StreamsBuilder
addGlobalStore, addGlobalStore, addStateStore, build, build, getNewTopology, globalTable, globalTable, globalTable, globalTable, stream, stream, stream, stream, stream, stream, table, table, table, table
-
Constructor Details
-
ConfiguredStreamBuilder
Default constructor.- Parameters:
configuration
- The configuration
-
-
Method Details
-
getConfiguration
The configuration. Can be mutated.- Returns:
- The configuration
-