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 f9934e7  MINOR: remove unused imports in Streams system tests (#7468)
     add e3c2148  KAFKA-8964: Rename tag client-id for thread-level metrics and 
below (#7429)

No new revisions were added by this update.

Summary of changes:
 .../streams/kstream/internals/metrics/Sensors.java | 24 ++------
 .../streams/processor/internals/ProcessorNode.java | 18 +-----
 .../streams/processor/internals/StreamTask.java    |  3 +-
 .../internals/metrics/StreamsMetricsImpl.java      | 64 ++++++++++++----------
 .../AbstractRocksDBSegmentedBytesStore.java        |  2 +-
 .../state/internals/InMemorySessionStore.java      |  2 +-
 .../state/internals/InMemoryWindowStore.java       |  4 +-
 .../streams/state/internals/metrics/Sensors.java   |  8 +--
 ...KStreamSessionWindowAggregateProcessorTest.java |  8 +--
 .../internals/KStreamWindowAggregateTest.java      |  8 +--
 .../KTableSuppressProcessorMetricsTest.java        | 18 +++---
 .../processor/internals/ProcessorNodeTest.java     |  4 +-
 .../processor/internals/StreamTaskTest.java        |  8 +--
 .../processor/internals/StreamThreadTest.java      | 16 +++---
 .../internals/metrics/StreamsMetricsImplTest.java  | 46 ++++++++++++++--
 .../AbstractRocksDBSegmentedBytesStoreTest.java    |  8 +--
 .../state/internals/MeteredKeyValueStoreTest.java  |  8 +--
 .../state/internals/MeteredSessionStoreTest.java   |  6 +-
 .../MeteredTimestampedKeyValueStoreTest.java       |  8 +--
 .../state/internals/MeteredWindowStoreTest.java    |  4 +-
 .../state/internals/SessionBytesStoreTest.java     |  8 +--
 .../state/internals/WindowBytesStoreTest.java      |  8 +--
 .../apache/kafka/streams/TopologyTestDriver.java   |  4 +-
 23 files changed, 146 insertions(+), 141 deletions(-)

Reply via email to