Page History

Step 1 in proposal: expose state store names to DSL and local queries

The stream store namespace is local to a KStreams instance, i.e., it is part of the same process that the KStreams instance is in. Conceptually the code to access such a store would look like this:Image RemovedImage Added

KafkaStreams streams = new KafkaStreams(..);

ReadOnlyKeyValueStore store = streams.getStore("storeName", QueryableStoreTypes.keyValueStore());

The state store is discovered by querying the KafkaStreams instance. The query operations will be read-only, i.e., no updates. The query method is calling methods of the StateStore object.