This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d88f104 KAFKA-8179: Part 7, cooperative rebalancing in Streams (#7386)
add cfa1067 KAFKA-7245: Deprecate WindowStore#put(key, value) (#7105)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/ProcessorContextImpl.java | 2 ++
.../java/org/apache/kafka/streams/state/WindowStore.java | 6 ++++++
.../streams/state/internals/CachingWindowStore.java | 1 +
.../state/internals/ChangeLoggingWindowBytesStore.java | 1 +
.../streams/state/internals/InMemoryWindowStore.java | 1 +
.../streams/state/internals/MeteredWindowStore.java | 1 +
.../streams/state/internals/RocksDBWindowStore.java | 1 +
.../state/internals/TimestampedWindowStoreBuilder.java | 1 +
.../WindowToTimestampedWindowByteStoreAdapter.java | 1 +
.../org/apache/kafka/streams/perf/SimpleBenchmark.java | 2 +-
.../processor/internals/ProcessorContextImplTest.java | 9 +++++++--
.../streams/state/internals/CachingWindowStoreTest.java | 16 +++++++++++++++-
.../ChangeLoggingTimestampedWindowBytesStoreTest.java | 2 ++
.../internals/ChangeLoggingWindowBytesStoreTest.java | 2 ++
.../streams/state/internals/InMemoryWindowStoreTest.java | 1 +
.../internals/MeteredTimestampedWindowStoreTest.java | 2 ++
.../streams/state/internals/MeteredWindowStoreTest.java | 1 +
.../streams/state/internals/RocksDBWindowStoreTest.java | 4 ++++
.../streams/state/internals/WindowBytesStoreTest.java | 8 ++++++++
.../kafka/streams/internals/WindowStoreFacade.java | 1 +
.../kafka/streams/internals/WindowStoreFacadeTest.java | 1 +
21 files changed, 60 insertions(+), 4 deletions(-)
