This is an automated email from the ASF dual-hosted git repository. guozhang pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
from 653baa66948 KAFKA-10199: Add task updater metrics, part 2 (#13300) add b2ee6df1c4c KAFKA-14172: Should clear cache when active recycled from standby (#13369) No new revisions were added by this update. Summary of changes: .../processor/internals/ActiveTaskCreator.java | 4 +- .../processor/internals/ProcessorStateManager.java | 20 +- .../processor/internals/StandbyTaskCreator.java | 2 +- .../processor/internals/StoreChangelogReader.java | 2 +- .../streams/state/internals/CachedStateStore.java | 10 + .../state/internals/CachingKeyValueStore.java | 12 + .../state/internals/CachingSessionStore.java | 5 + .../state/internals/CachingWindowStore.java | 5 + .../kafka/streams/state/internals/NamedCache.java | 7 + .../kafka/streams/state/internals/ThreadCache.java | 8 + .../internals/TimeOrderedCachingWindowStore.java | 5 + .../streams/state/internals/WrappedStateStore.java | 8 + ...tandbyTaskEOSMultiRebalanceIntegrationTest.java | 300 +++++++++++++++++++++ .../internals/ProcessorStateManagerTest.java | 29 ++ 14 files changed, 411 insertions(+), 6 deletions(-) create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSMultiRebalanceIntegrationTest.java