kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (7746301 -> 05b2361)
Date Thu, 30 Jan 2020 07:46:37 GMT
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


Mime
View raw message