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 9d602a0 KAFKA-12648: invoke exception handler for
MissingSourceTopicException with named topologies (#11686)
add 96fa468 MINOR: fix NPE in iqv2 (#11702)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/streams/query/QueryResult.java | 24 ++++--
.../state/internals/InMemoryKeyValueStore.java | 2 +-
.../state/internals/InMemorySessionStore.java | 2 +-
.../state/internals/InMemoryWindowStore.java | 2 +-
.../state/internals/MemoryNavigableLRUCache.java | 2 +-
.../state/internals/RocksDBSessionStore.java | 2 +-
.../streams/state/internals/RocksDBStore.java | 2 +-
.../state/internals/RocksDBWindowStore.java | 2 +-
.../streams/state/internals/StoreQueryUtils.java | 10 ++-
.../state/internals/StoreQueryUtilsTest.java | 85 ++++++++++++++++++++++
10 files changed, 115 insertions(+), 18 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/StoreQueryUtilsTest.java
