Interface QueryableKafkaStreams
-
- All Superinterfaces:
QueryCall.QueryCallFactory
- All Known Subinterfaces:
KafkaStreamsContainer
- All Known Implementing Classes:
LocalKafkaStreamsContainer
public interface QueryableKafkaStreams extends QueryCall.QueryCallFactory
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <K,V>
QueryCall<K,V>newQueryCall(QueryRequest request)
Creates a newQueryCall
for specifiedQueryRequest
.
-
-
-
Method Detail
-
newQueryCall
<K,V> QueryCall<K,V> newQueryCall(QueryRequest request) throws InvalidQueryException
Creates a newQueryCall
for specifiedQueryRequest
.- Specified by:
newQueryCall
in interfaceQueryCall.QueryCallFactory
- Type Parameters:
K
- the expected type for record-key.V
- the expected type for record-value.- Parameters:
request
- the query.- Returns:
- a new
QueryCall
object. - Throws:
InvalidQueryException
- if the given request is invalid.
-
-