StoreSupplier Contract — State Store Suppliers for High-Level Streams DSL

StoreSupplier is the abstraction of state store suppliers that can create state stores in the Streams DSL — High-Level Stream Processing DSL.

Kafka Streams developers usually create a StoreSupplier using Stores utility. The StoreSupplier can then be further customized using Materialized.

Note
 When using the Low-Level Processor API, Kafka Streams developers use StoreBuilders instead that are then attached to Processors.
Table 1. StoreSupplier Contract
Method Description

get

 
T get()

Supplies a state store (as T)

Used when StoreBuilders (i.e. KeyValueStoreBuilder, SessionStoreBuilder and WindowStoreBuilder) are requested to build a KeyValueStore

metricsScope

 
String metricsScope()

Metric scope for the metrics recorded by Metered stores (e.g. MeteredKeyValueBytesStore, MeteredSessionStore and MeteredWindowStore)

Used when:

name

 
String name()

Name of the state store (for identification purposes)

Used when:
Table 2. StoreSuppliers (Interfaces)
StoreSupplier Description

KeyValueBytesStoreSupplier

SessionBytesStoreSupplier

WindowBytesStoreSupplier

results matching ""

    No results matching ""