Interface InteractiveQueryService

  • All Known Implementing Classes:
    DefaultInteractiveQueryService

    public interface InteractiveQueryService
    A InteractiveQueryService can be used to query a KafkaStreams state store.
    • 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 - the application.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.