You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/01/30 07:46:37 UTC
[kafka] branch trunk updated (7746301 -> 05b2361)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7746301 KAFKA-9422: Track the set of topics a connector is using (KIP-558) (#8017)
add 05b2361 KAFKA-9445: Allow adding changes to allow serving from a specific partition (#7984)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 38 +--
.../org/apache/kafka/streams/StoreQueryParams.java | 138 +++++++++
.../internals/InternalTopologyBuilder.java | 4 +-
.../state/internals/QueryableStoreProvider.java | 19 +-
.../internals/StreamThreadStateStoreProvider.java | 40 ++-
.../state/internals/WrappingStoreProvider.java | 14 +-
.../streams/integration/EosIntegrationTest.java | 3 +-
.../GlobalKTableEOSIntegrationTest.java | 9 +-
.../integration/GlobalKTableIntegrationTest.java | 19 +-
.../KStreamAggregationIntegrationTest.java | 5 +-
.../OptimizedKTableIntegrationTest.java | 7 +-
.../integration/QueryableStateIntegrationTest.java | 46 +--
.../integration/StoreQueryIntegrationTest.java | 344 +++++++++++++++++++++
.../integration/StoreUpgradeIntegrationTest.java | 19 +-
.../StreamStreamJoinIntegrationTest.java | 3 +-
.../CompositeReadOnlyKeyValueStoreTest.java | 16 +-
.../CompositeReadOnlySessionStoreTest.java | 10 +-
.../CompositeReadOnlyWindowStoreTest.java | 6 +-
.../internals/QueryableStoreProviderTest.java | 15 +-
.../StreamThreadStateStoreProviderTest.java | 41 +--
.../state/internals/WrappingStoreProviderTest.java | 10 +-
.../apache/kafka/test/StateStoreProviderStub.java | 9 +-
22 files changed, 669 insertions(+), 146 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/StoreQueryParams.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java