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 71c5729 KAFKA-6144: Add KeyQueryMetadata APIs to KafkaStreams (#7960)
add 0c76fbb KAFKA-6144: IQ option to query standbys (#7962)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 59 ++++++++----
.../streams/processor/internals/StreamThread.java | 19 ++--
.../state/internals/QueryableStoreProvider.java | 22 +++--
.../internals/StreamThreadStateStoreProvider.java | 56 +++++++-----
.../state/internals/WrappingStoreProvider.java | 23 ++---
.../integration/QueryableStateIntegrationTest.java | 101 +++++++++++++++++++--
.../kafka/streams/integration/StoreQuerySuite.java | 49 ++++++++++
.../integration/SuppressionIntegrationTest.java | 2 +-
.../processor/internals/StreamThreadTest.java | 18 ++--
.../CompositeReadOnlyKeyValueStoreTest.java | 18 ++--
.../CompositeReadOnlySessionStoreTest.java | 15 +--
.../CompositeReadOnlyWindowStoreTest.java | 62 ++++++++++---
.../internals/QueryableStoreProviderTest.java | 18 ++--
.../StreamThreadStateStoreProviderTest.java | 39 ++++----
.../state/internals/WrappingStoreProviderTest.java | 4 +-
.../apache/kafka/test/StateStoreProviderStub.java | 10 +-
16 files changed, 365 insertions(+), 150 deletions(-)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/StoreQuerySuite.java
|