You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2023/04/24 21:12:16 UTC
[kafka] branch 3.5 updated (a0e13b5793f -> b0c8bafdff2)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch 3.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
from a0e13b5793f KAFKA-14862: Outer stream-stream join does not output all results with multiple input partitions (#13592)
add b0c8bafdff2 KAFKA-14834: [12/N] Minor code cleanups relating to versioned stores (#13615)
No new revisions were added by this update.
Summary of changes:
.../kstream/internals/KTableRepartitionMap.java | 5 +-
.../kstream/internals/KTableTransformValues.java | 8 +-
.../apache/kafka/streams/state/KeyValueStore.java | 5 +
.../kafka/streams/state/ReadOnlyKeyValueStore.java | 1 +
.../streams/state/VersionedKeyValueStore.java | 2 +
.../apache/kafka/streams/state/WindowStore.java | 1 +
.../internals/MeteredVersionedKeyValueStore.java | 16 +-
.../state/internals/RocksDBVersionedStore.java | 21 +-
.../integration/TableTableJoinIntegrationTest.java | 476 ++++++++++-----------
9 files changed, 280 insertions(+), 255 deletions(-)