This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e82df83 KAFKA-13374: Update doc to mention read from leader/followers
(#11408)
add 5747788 KAFKA-13525: Implement KeyQuery in Streams IQv2 (#11582)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/streams/query/FailureReason.java | 7 +
.../org/apache/kafka/streams/query/KeyQuery.java | 35 +++--
.../apache/kafka/streams/query/QueryResult.java | 13 ++
.../org/apache/kafka/streams/query/RangeQuery.java | 8 +-
.../state/internals/MeteredKeyValueStore.java | 90 +++++++----
.../kafka/streams/state/internals/PingQuery.java | 29 ----
.../streams/state/internals/StoreQueryUtils.java | 48 ++++--
.../streams/integration/IQv2IntegrationTest.java | 42 +++---
.../integration/IQv2StoreIntegrationTest.java | 164 ++++++++++-----------
9 files changed, 245 insertions(+), 191 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialAlteration.java
=> streams/src/main/java/org/apache/kafka/streams/query/KeyQuery.java (51%)
delete mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/PingQuery.java
