You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2022/01/26 15:39:47 UTC
[kafka] branch trunk updated (000ba03 -> fe72187)
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 000ba03 KAFKA-9279: Fail producer transactions for asynchronously-reported, synchronously-encountered ApiExceptions (#11508)
add fe72187 KAFKA-13524: Add IQv2 query handling to the caching layer (#11682)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 3 +-
.../apache/kafka/streams/processor/StateStore.java | 13 ++-
.../org/apache/kafka/streams/query/KeyQuery.java | 21 +++-
.../apache/kafka/streams/query/QueryConfig.java | 26 ++---
.../AbstractRocksDBSegmentedBytesStore.java | 3 +-
.../state/internals/CachingKeyValueStore.java | 123 ++++++++++++++++++++-
.../internals/ChangeLoggingKeyValueBytesStore.java | 6 +-
.../ChangeLoggingListValueBytesStore.java | 1 -
.../internals/ChangeLoggingSessionBytesStore.java | 9 +-
...ChangeLoggingTimestampedKeyValueBytesStore.java | 4 +-
.../ChangeLoggingTimestampedWindowBytesStore.java | 4 +-
.../internals/ChangeLoggingWindowBytesStore.java | 6 +-
.../state/internals/InMemoryKeyValueStore.java | 7 +-
.../state/internals/InMemorySessionStore.java | 8 +-
.../InMemoryTimeOrderedKeyValueBuffer.java | 6 +
.../state/internals/InMemoryWindowStore.java | 8 +-
.../state/internals/KeyValueStoreBuilder.java | 2 +-
...ValueToTimestampedKeyValueByteStoreAdapter.java | 15 ++-
.../state/internals/ListValueStoreBuilder.java | 2 +-
.../streams/state/internals/MemoryLRUCache.java | 7 +-
.../state/internals/MemoryNavigableLRUCache.java | 7 +-
.../state/internals/MeteredKeyValueStore.java | 29 +++--
.../state/internals/MeteredSessionStore.java | 17 +--
.../state/internals/MeteredWindowStore.java | 27 ++---
.../state/internals/RocksDBSessionStore.java | 8 +-
.../streams/state/internals/RocksDBStore.java | 8 +-
.../state/internals/RocksDBWindowStore.java | 8 +-
.../streams/state/internals/StoreQueryUtils.java | 19 ++--
.../internals/TimestampedKeyValueStoreBuilder.java | 17 ++-
.../internals/TimestampedWindowStoreBuilder.java | 15 ++-
.../internals/ValueAndTimestampDeserializer.java | 1 -
.../WindowToTimestampedWindowByteStoreAdapter.java | 15 ++-
.../streams/state/internals/WrappedStateStore.java | 15 ++-
.../streams/integration/IQv2IntegrationTest.java | 14 +++
.../kafka/streams/state/NoOpWindowStore.java | 6 +
.../CachingInMemoryKeyValueStoreTest.java | 8 +-
.../ChangeLoggingSessionBytesStoreTest.java | 8 +-
...angeLoggingTimestampedWindowBytesStoreTest.java | 4 +
.../ChangeLoggingWindowBytesStoreTest.java | 6 +-
.../state/internals/ReadOnlyWindowStoreStub.java | 6 +
.../state/internals/StoreQueryUtilsTest.java | 5 +-
.../org/apache/kafka/test/MockKeyValueStore.java | 6 +
.../org/apache/kafka/test/NoOpReadOnlyStore.java | 6 +
.../kafka/test/ReadOnlySessionStoreStub.java | 6 +
.../apache/kafka/streams/TopologyTestDriver.java | 11 ++
45 files changed, 405 insertions(+), 141 deletions(-)
copy clients/src/main/java/org/apache/kafka/common/errors/IllegalGenerationException.java => streams/src/main/java/org/apache/kafka/streams/query/QueryConfig.java (65%)