This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 0dbf95b MINOR: Fix documentation for updateCurrentReassignment (#7611) add fc0f823 KAFKA-8980: Refactor state-store-level streams metrics (#7584) No new revisions were added by this update. Summary of changes: .../internals/metrics/StreamsMetricsImpl.java | 39 +- .../processor/internals/metrics/TaskMetrics.java | 14 +- .../processor/internals/metrics/ThreadMetrics.java | 4 +- .../AbstractRocksDBSegmentedBytesStore.java | 18 +- .../state/internals/InMemorySessionStore.java | 20 +- .../InMemoryTimeOrderedKeyValueBuffer.java | 29 +- .../state/internals/InMemoryWindowStore.java | 17 +- .../state/internals/MeteredKeyValueStore.java | 238 ++------- .../state/internals/MeteredSessionStore.java | 174 ++----- .../state/internals/MeteredWindowStore.java | 150 ++---- .../state/internals/metrics/NamedCacheMetrics.java | 4 +- .../state/internals/metrics/RocksDBMetrics.java | 38 +- .../streams/state/internals/metrics/Sensors.java | 117 ----- .../state/internals/metrics/StateStoreMetrics.java | 569 +++++++++++++++++++++ .../integration/MetricsIntegrationTest.java | 389 ++++++++++---- .../kstream/internals/metrics/TaskMetricsTest.java | 39 +- .../KTableSuppressProcessorMetricsTest.java | 164 ++++-- .../internals/metrics/StreamsMetricsImplTest.java | 21 +- .../internals/metrics/ThreadMetricsTest.java | 24 +- .../AbstractRocksDBSegmentedBytesStoreTest.java | 91 +++- .../state/internals/MeteredKeyValueStoreTest.java | 94 +++- .../state/internals/MeteredSessionStoreTest.java | 88 +++- .../MeteredTimestampedKeyValueStoreTest.java | 96 +++- .../state/internals/MeteredWindowStoreTest.java | 148 +++++- .../state/internals/SessionBytesStoreTest.java | 95 +++- .../state/internals/WindowBytesStoreTest.java | 95 +++- .../internals/metrics/NamedCacheMetricsTest.java | 2 +- .../internals/metrics/StateStoreMetricsTest.java | 457 +++++++++++++++++ .../kafka/test/InternalMockProcessorContext.java | 16 +- 29 files changed, 2317 insertions(+), 933 deletions(-) delete mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/Sensors.java create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetricsTest.java