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 bebb9ae KAFKA-13132; Ensure topicId is updated on replicas even when
the leader epoch is unchanged (#11126)
add 2254136 Add support for infinite endpoints for range queries (#11120)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/common/utils/Utils.java | 12 +
.../kafka/streams/state/ReadOnlyKeyValueStore.java | 6 +-
.../state/internals/CachingKeyValueStore.java | 4 +-
.../internals/CompositeReadOnlyKeyValueStore.java | 4 -
.../state/internals/InMemoryKeyValueStore.java | 26 +-
.../state/internals/MemoryNavigableLRUCache.java | 57 ++--
.../state/internals/MeteredKeyValueStore.java | 12 +-
.../kafka/streams/state/internals/NamedCache.java | 28 +-
.../state/internals/RocksDBRangeIterator.java | 22 +-
.../streams/state/internals/RocksDBStore.java | 5 +-
.../state/internals/RocksDBTimestampedStore.java | 28 +-
.../integration/KTableEfficientRangeQueryTest.java | 262 ++++++++++++++++++
.../integration/RangeQueryIntegrationTest.java | 303 +++++++++++++++++++++
.../state/internals/AbstractKeyValueStoreTest.java | 92 ++++++-
.../CompositeReadOnlyKeyValueStoreTest.java | 59 +++-
.../streams/state/internals/RocksDBStoreTest.java | 29 +-
16 files changed, 856 insertions(+), 93 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/integration/KTableEfficientRangeQueryTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/integration/RangeQueryIntegrationTest.java
