Interface InteractiveQueryService
-
- All Known Implementing Classes:
DefaultInteractiveQueryService
public interface InteractiveQueryService
AInteractiveQueryService
can be used to query aKafkaStreams
state store.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <K,V>
QueryResult<K,V>execute(String applicationId, QueryRequest queryObject, QueryOptions queryOptions)
Executes an interactive query for the specified streams application.
-
-
-
Method Detail
-
execute
<K,V> QueryResult<K,V> execute(String applicationId, QueryRequest queryObject, QueryOptions queryOptions)
Executes an interactive query for the specified streams application.- Parameters:
applicationId
- theapplication.id
of the Kafka Streams to query.queryObject
- the query object to be executed.queryOptions
- the options of the query.- Returns:
- the
QueryResult
instance. - Throws:
InvalidStreamsStateException
- if the streams is not running for the given applicationId.
-
-