StoreSupplier Contract — State Store Suppliers for High-Level Streams 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)

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 ""