public interface DslStoreSuppliers
extends org.apache.kafka.common.ConfigurableDslStoreSuppliers 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):
Materialized.as(DslStoreSuppliers), Materialized.withStoreType(DslStoreSuppliers), or StreamJoined.withDslStoreSuppliers(DslStoreSuppliers)TopologyConfig and passed into the StreamsBuilder(TopologyConfig) constructorStreamsConfig using the StreamsConfig.DSL_STORE_SUPPLIERS_CLASS_CONFIGKafka Streams is packaged with some pre-existing DslStoreSuppliers that exist in BuiltInDslStoreSuppliers
| Modifier and Type | Method and Description |
|---|---|
default void | configure(Map<String,?> configs) |
KeyValueBytesStoreSupplier | keyValueStore(DslKeyValueParams params) |
SessionBytesStoreSupplier | sessionStore(DslSessionParams params) |
WindowBytesStoreSupplier | windowStore(DslWindowParams params) |
default void configure(Map<String,?> configs)
configure in interface org.apache.kafka.common.ConfigurableKeyValueBytesStoreSupplier keyValueStore(DslKeyValueParams params)
WindowBytesStoreSupplier windowStore(DslWindowParams params)
SessionBytesStoreSupplier sessionStore(DslSessionParams params)