Package org.apache.kafka.streams.state
Interface DslStoreSuppliers
- All Superinterfaces:
Configurable
- All Known Implementing Classes:
BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers
,BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers
,Materialized.StoreType
DslStoreSuppliers
defines a grouping of factories to construct
stores for each of the types of state store implementations in Kafka
Streams. This allows configuration of a default store supplier beyond
the builtin defaults of RocksDB and In-Memory.
There are various ways that this configuration can be supplied to the application (in order of precedence):
- Passed in directly to a DSL operator via either
Materialized.as(DslStoreSuppliers)
,Materialized.withStoreType(DslStoreSuppliers)
, orStreamJoined.withDslStoreSuppliers(DslStoreSuppliers)
- Passed in via a Topology configuration override (configured in a
TopologyConfig
and passed into theStreamsBuilder(TopologyConfig)
constructor - Configured as a global default in
StreamsConfig
using theStreamsConfig.DSL_STORE_SUPPLIERS_CLASS_CONFIG
configuration.
Kafka Streams is packaged with some pre-existing DslStoreSuppliers
that exist in BuiltInDslStoreSuppliers
-
Method Summary
Modifier and TypeMethodDescriptiondefault void
Configure this class with the given key-value pairskeyValueStore
(DslKeyValueParams params) sessionStore
(DslSessionParams params) windowStore
(DslWindowParams params)
-
Method Details
-
configure
Description copied from interface:Configurable
Configure this class with the given key-value pairs- Specified by:
configure
in interfaceConfigurable
-
keyValueStore
-
windowStore
-
sessionStore
-