...
We propose adding an additional method to the KafkaStreams public API:
Code Block |
---|
/**
* Find the store with the provided storeName and of the type as
* specified by QueryableStoreType. Will throw an UnknownStoreException
* if a store with the given name and type is not found
*/
public <T> T store(final String storeName,
final QueryableStoreType<T> queryableStoreType) |
...