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 2021/12/08 18:01:52 UTC
[kafka] branch trunk updated (9e57958 -> 7acd12d)
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 9e57958 MINOR: Bump version of grgit to 4.1.1 (#11561)
add 7acd12d KAFKA-13506: Write and restore position to/from changelog (#11513)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/StreamsConfig.java | 5 +
.../internals/AbstractProcessorContext.java | 2 +-
.../ChangelogRecordDeserializationHelper.java | 75 ++++++
.../internals/GlobalProcessorContextImpl.java | 4 +-
.../internals/InternalProcessorContext.java | 4 +-
.../processor/internals/ProcessorContextImpl.java | 28 +-
.../AbstractRocksDBSegmentedBytesStore.java | 125 +++++----
.../state/internals/CachingKeyValueStore.java | 3 +-
.../internals/ChangeLoggingKeyValueBytesStore.java | 15 +-
.../ChangeLoggingListValueBytesStore.java | 1 +
.../internals/ChangeLoggingSessionBytesStore.java | 15 +-
...ChangeLoggingTimestampedKeyValueBytesStore.java | 4 +-
.../ChangeLoggingTimestampedWindowBytesStore.java | 4 +-
.../internals/ChangeLoggingWindowBytesStore.java | 15 +-
.../streams/state/internals/PositionSerde.java | 107 ++++++++
.../state/internals/RocksDBSessionStore.java | 1 -
.../streams/state/internals/RocksDBStore.java | 137 +++++-----
.../state/internals/RocksDBTimestampedStore.java | 1 +
.../state/internals/RocksDBWindowStore.java | 1 -
....java => ConsistencyVectorIntegrationTest.java} | 203 ++++++++-------
.../internals/AbstractProcessorContextTest.java | 4 +-
.../internals/ProcessorContextImplTest.java | 81 +++++-
.../internals/WriteConsistencyVectorTest.java | 151 +++++++++++
.../AbstractRocksDBSegmentedBytesStoreTest.java | 282 ++++++++++++++++++++-
.../CachingInMemoryKeyValueStoreTest.java | 25 +-
.../ChangeLoggingKeyValueBytesStoreTest.java | 65 ++++-
.../ChangeLoggingSessionBytesStoreTest.java | 55 +++-
...angeLoggingTimestampedWindowBytesStoreTest.java | 49 +++-
.../ChangeLoggingWindowBytesStoreTest.java | 50 +++-
.../internals/GlobalStateStoreProviderTest.java | 4 +
.../state/internals/InMemoryKeyValueStoreTest.java | 42 +--
.../state/internals/InMemorySessionStoreTest.java | 36 +--
.../state/internals/InMemoryWindowStoreTest.java | 37 ++-
.../state/internals/RocksDBSessionStoreTest.java | 36 +--
.../streams/state/internals/RocksDBStoreTest.java | 210 +++++++++++++--
.../state/internals/RocksDBWindowStoreTest.java | 36 ++-
.../kafka/test/InternalMockProcessorContext.java | 32 ++-
.../test/MockInternalNewProcessorContext.java | 4 +-
.../kafka/test/MockInternalProcessorContext.java | 6 +-
.../apache/kafka/test/NoOpProcessorContext.java | 15 +-
40 files changed, 1537 insertions(+), 433 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/PositionSerde.java
copy streams/src/test/java/org/apache/kafka/streams/integration/{OptimizedKTableIntegrationTest.java => ConsistencyVectorIntegrationTest.java} (57%)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/WriteConsistencyVectorTest.java