Package io.micronaut.configuration.kafka.streams

Class InteractiveQueryService

java.lang.Object

io.micronaut.configuration.kafka.streams.InteractiveQueryService

public class InteractiveQueryService
extends Object

Services to facilitate the interactive query capabilities of Kafka Streams. This class provides services such as querying for a particular store. This is part of the public API of the kafka streams binder and the users can inject this service in their applications to make use of it.

Since:

1.1.1

Author:

Christian Oestreich

Method Summary

Modifier and Type	Method	Description
<T> Optional<T>	getQueryableStore(String storeName, QueryableStoreType<T> storeType)	Retrieve and return a queryable store by name created in the application.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getQueryableStore

public <T> Optional<T> getQueryableStore(String storeName,
 QueryableStoreType<T> storeType)

Retrieve and return a queryable store by name created in the application. If state store is not present an Optional.empty() will be returned.

Type Parameters:

T - generic queryable store

Parameters:

storeName - name of the queryable store

storeType - type of the queryable store

Returns:

queryable store.