kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (c5dfb90 -> bab3e08)
Date Tue, 17 Sep 2019 04:49:00 GMT
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 c5dfb90  MINOR: Cleanup scala warnings (#7335)
     add bab3e08  KAFKA-8859: Expose built-in streams metrics version in `StreamsMetricsImpl`
(#7323)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/GlobalStreamThread.java    |  6 +++-
 .../streams/processor/internals/StreamThread.java  |  6 +++-
 .../internals/metrics/StreamsMetricsImpl.java      | 24 ++++++++++++-
 .../processor/internals/MockStreamsMetrics.java    |  3 +-
 .../processor/internals/StandbyTaskTest.java       |  3 +-
 .../processor/internals/StreamThreadTest.java      | 26 ++++++++------
 .../internals/metrics/StreamsMetricsImplTest.java  | 42 ++++++++++++++--------
 .../internals/GlobalStateStoreProviderTest.java    |  5 ++-
 .../MeteredTimestampedWindowStoreTest.java         |  3 +-
 .../state/internals/MeteredWindowStoreTest.java    |  3 +-
 .../kafka/test/InternalMockProcessorContext.java   | 26 +++++++++++---
 .../apache/kafka/streams/TopologyTestDriver.java   |  6 +++-
 .../streams/processor/MockProcessorContext.java    |  2 +-
 13 files changed, 116 insertions(+), 39 deletions(-)


Mime
View raw message