Module request 

IQv2 request envelope: Position/PositionBound (KIP-796 bounded staleness), partition selection, and the finalized StateQuery<Q> that KafkaStreams::query consumes.

Structs

Position

Source-topic consumed offsets folded into a store, as topic to partition to offset. The offset is the next offset to read, one past the last consumed record.

StateQuery

A finalized IQv2 request, built with StateQueryRequest::in_store(name).with_query(q).

StateQueryRequest

Entry point namespace: StateQueryRequest::in_store("s").with_query(q).

StateQueryRequestBuilder

Half-built request that waits for .with_query(q).

Enums

PositionBound

Freshness bound for a query (KIP-796). At requires each partition’s Position to dominate the given one. Otherwise that partition fails fast with NotUpToBound, and the query never blocks.