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 f653cb7 KAFKA-13488: Producer fails to recover if topic gets deleted
midway (#11552)
add b38f6ba KAFKA-13479: Implement range and scan queries (#11598)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/streams/query/FailureReason.java | 9 +-
.../apache/kafka/streams/query/QueryResult.java | 2 +-
.../org/apache/kafka/streams/query/RangeQuery.java | 108 +++++++++++
.../state/internals/InMemoryKeyValueStore.java | 10 ++
.../state/internals/MemoryNavigableLRUCache.java | 10 ++
.../state/internals/MeteredKeyValueStore.java | 140 +++++++++++++++
.../streams/state/internals/RocksDBStore.java | 1 +
.../streams/state/internals/StoreQueryUtils.java | 103 ++++++++++-
.../integration/IQv2StoreIntegrationTest.java | 198 +++++++++++++++++++--
9 files changed, 553 insertions(+), 28 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/query/RangeQuery.java
