Package org.springframework.kafka.streams

Class KafkaStreamsInteractiveQueryService

java.lang.Object

org.springframework.kafka.streams.KafkaStreamsInteractiveQueryService

public class KafkaStreamsInteractiveQueryService
extends Object

Provide a wrapper API around the interactive query stores in Kafka Streams. Using this API, an application can gain access to a named state store in the KafkaStreams under consideration.

Since:

3.2

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsInteractiveQueryService(StreamsBuilderFactoryBean streamsBuilderFactoryBean)	Construct an instance for querying state stores from the KafkaStreams in the StreamsBuilderFactoryBean.

Method Summary

Modifier and Type	Method	Description
<T> T	retrieveQueryableStore(String storeName, org.apache.kafka.streams.state.QueryableStoreType<T> storeType)	Retrieve and return a queryable store by name created in the application.
void	setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)	Custom RetryTemplate provided by the end users.

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaStreamsInteractiveQueryService

public KafkaStreamsInteractiveQueryService(StreamsBuilderFactoryBean streamsBuilderFactoryBean)

Construct an instance for querying state stores from the KafkaStreams in the StreamsBuilderFactoryBean.

Parameters:

streamsBuilderFactoryBean - StreamsBuilderFactoryBean for KafkaStreams.

Method Details

setRetryTemplate

public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

Custom RetryTemplate provided by the end users.

Parameters:

retryTemplate - RetryTemplate

retrieveQueryableStore

public <T> T retrieveQueryableStore(String storeName,
 org.apache.kafka.streams.state.QueryableStoreType<T> storeType)

Retrieve and return a queryable store by name created in the application.

Type Parameters:

T - generic type for the queryable store

Parameters:

storeName - name of the queryable store

storeType - type of the queryable store

Returns:

queryable store.