io.micronaut.configuration.kafka.streams

Class InteractiveQueryService

java.lang.Object

io.micronaut.configuration.kafka.streams.InteractiveQueryService

public class InteractiveQueryService
extends java.lang.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 and Description
<T> java.util.Optional<T>	getQueryableStore(java.lang.String storeName, org.apache.kafka.streams.state.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 Detail

getQueryableStore

public <T> java.util.Optional<T> getQueryableStore(java.lang.String storeName,
                                                   org.apache.kafka.streams.state.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.