Package org.apache.kafka.streams.query

package org.apache.kafka.streams.query

Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.

Related Packages

Package	Description
org.apache.kafka.streams	Provides the Kafka Streams library for building streaming data applications.
org.apache.kafka.streams.errors	Provides common exception classes for Streams applications.
org.apache.kafka.streams.kstream	Provides a high-level programming model (DSL) to express a (stateful) data flow computation over input streams and tables.
org.apache.kafka.streams.processor	Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
org.apache.kafka.streams.state	Provides interfaces for managing the intermediate state of a stateful streams application.
org.apache.kafka.streams.test	Provides classes for testing Kafka Streams applications with mocked inputs.

Class	Description
FailureReason	This enumeration type captures the various top-level reasons that a particular partition of a store would fail to execute a query.
KeyQuery<K,V>	Interactive query for retrieving a single record based on its key.
MultiVersionedKeyQuery<K,V>	Interactive query for retrieving a set of records with the same specified key and different timestamps within the specified time range.
Position	A representation of a position vector with respect to a set of topic partitions.
PositionBound	A class bounding the processing state Position during queries.
Query<R>	Marker interface that all interactive queries must implement (see KafkaStreams.query(StateQueryRequest)).
QueryConfig	Runtime configuration parameters
QueryResult<R>	Container for a single partition's result when executing a StateQueryRequest.
RangeQuery<K,V>	Interactive query for issuing range queries and scans over KeyValue stores.
ResultOrder
StateQueryRequest<R>	The request object for Interactive Queries.
StateQueryRequest.InStore	A progressive builder interface for creating StoreQueryRequests.
StateQueryResult<R>	The response object for interactive queries.
TimestampedKeyQuery<K,V>	Interactive query for retrieving a single record based on its key from TimestampedKeyValueStore
TimestampedKeyWithHeadersQuery<K,V>	Interactive query for retrieving a single record, including its record headers, based on its key from a TimestampedKeyValueStoreWithHeaders.
TimestampedRangeQuery<K,V>	Interactive query for issuing range queries and scans over TimestampedKeyValueStore
TimestampedRangeWithHeadersQuery<K,V>	Interactive query for issuing range queries and scans over a TimestampedKeyValueStoreWithHeaders, returning each record together with its headers.
TimestampedWindowKeyWithHeadersQuery<K,V>	Interactive query for retrieving records of a single key across a window-start range, including their record headers, from a TimestampedWindowStoreWithHeaders.
TimestampedWindowRangeWithHeadersQuery<K,V>	Interactive query for retrieving records across a window-start range or for a single key's sessions, including their record headers, from a TimestampedWindowStoreWithHeaders or a SessionStoreWithHeaders.
VersionedKeyQuery<K,V>	Interactive query for retrieving a single record from a versioned state store based on its key and timestamp.
WindowKeyQuery<K,V>
WindowRangeQuery<K,V>