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 (3b05dc6 -> 52007e8)
Date Sat, 05 Oct 2019 00:08:34 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 3b05dc6  MINOR: just remove leader on trunk like we did on 2.3 (#7447)
     add 52007e8  KAFKA-8934: Introduce instance-level metrics for streams applications (#7416)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  22 +-
 .../streams/internals/metrics/ClientMetrics.java   | 116 +++++++++
 .../kstream/internals/KStreamAggregate.java        |   2 +-
 .../kstream/internals/KStreamKStreamJoin.java      |   2 +-
 .../internals/KStreamKTableJoinProcessor.java      |   2 +-
 .../streams/kstream/internals/KStreamReduce.java   |   2 +-
 .../internals/KStreamSessionWindowAggregate.java   |   2 +-
 .../kstream/internals/KStreamWindowAggregate.java  |   2 +-
 .../kstream/internals/KTableKTableInnerJoin.java   |   2 +-
 .../kstream/internals/KTableKTableLeftJoin.java    |   2 +-
 .../kstream/internals/KTableKTableOuterJoin.java   |   2 +-
 .../kstream/internals/KTableKTableRightJoin.java   |   2 +-
 .../streams/kstream/internals/KTableSource.java    |   2 +-
 .../ForeignJoinSubscriptionProcessorSupplier.java  |   3 +-
 .../SubscriptionStoreReceiveProcessorSupplier.java |   2 +-
 .../streams/kstream/internals/metrics/Sensors.java |  26 +-
 .../processor/internals/GlobalStateUpdateTask.java |   2 +-
 .../processor/internals/GlobalStreamThread.java    |  20 +-
 .../streams/processor/internals/ProcessorNode.java |  48 +++-
 .../streams/processor/internals/RecordQueue.java   |   3 +-
 .../streams/processor/internals/StandbyTask.java   |   3 +-
 .../streams/processor/internals/StreamTask.java    |  33 ++-
 .../streams/processor/internals/StreamThread.java  |  64 ++---
 .../internals/metrics/StreamsMetricsImpl.java      | 273 +++++++++++++++------
 .../processor/internals/metrics/ThreadMetrics.java | 170 +++++++------
 .../AbstractRocksDBSegmentedBytesStore.java        |   4 +-
 .../state/internals/InMemorySessionStore.java      |   4 +-
 .../state/internals/InMemoryWindowStore.java       |   4 +-
 .../streams/state/internals/KeyValueSegments.java  |   2 +-
 .../state/internals/MeteredKeyValueStore.java      | 119 ++++++++-
 .../state/internals/MeteredSessionStore.java       |  70 +++++-
 .../state/internals/MeteredWindowStore.java        |  58 ++++-
 .../kafka/streams/state/internals/NamedCache.java  |   9 +-
 .../streams/state/internals/RocksDBStore.java      |   2 +-
 .../state/internals/TimestampedSegments.java       |   2 +-
 .../state/internals/metrics/NamedCacheMetrics.java |   8 +-
 .../state/internals/metrics/RocksDBMetrics.java    | 159 +++++++++---
 .../internals/metrics/RocksDBMetricsRecorder.java  |   9 +-
 .../streams/state/internals/metrics/Sensors.java   |  18 +-
 .../org/apache/kafka/streams/KafkaStreamsTest.java |  36 ++-
 .../integration/MetricsIntegrationTest.java        |  57 ++++-
 .../internals/metrics/ClientMetricsTest.java       | 137 +++++++++++
 ...KStreamSessionWindowAggregateProcessorTest.java |  11 +-
 .../internals/KStreamWindowAggregateTest.java      |   9 +-
 .../KTableSuppressProcessorMetricsTest.java        |  65 ++---
 .../internals/GlobalStreamThreadTest.java          |  11 +-
 .../processor/internals/ProcessorNodeTest.java     |   7 +-
 .../processor/internals/StandbyTaskTest.java       |   3 +-
 .../processor/internals/StreamTaskTest.java        |  20 +-
 .../processor/internals/StreamThreadTest.java      | 190 +++++++-------
 .../internals/metrics/StreamsMetricsImplTest.java  | 237 +++++++++++++++---
 .../internals/metrics/ThreadMetricsTest.java       |  49 ++--
 .../AbstractRocksDBSegmentedBytesStoreTest.java    |   5 +-
 .../state/internals/KeyValueSegmentTest.java       |   3 +-
 .../state/internals/MeteredKeyValueStoreTest.java  |   6 +-
 .../state/internals/MeteredSessionStoreTest.java   |   7 +-
 .../MeteredTimestampedKeyValueStoreTest.java       |   7 +-
 .../state/internals/MeteredWindowStoreTest.java    |   5 +-
 .../state/internals/SegmentIteratorTest.java       |   3 +-
 .../state/internals/SessionBytesStoreTest.java     |   5 +-
 .../state/internals/TimestampedSegmentTest.java    |   3 +-
 .../state/internals/WindowBytesStoreTest.java      |   5 +-
 .../internals/metrics/NamedCacheMetricsTest.java   |  16 +-
 .../metrics/RocksDBMetricsRecorderTest.java        |   5 +-
 .../internals/metrics/RocksDBMetricsTest.java      |  21 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |  11 +-
 .../streams/processor/MockProcessorContext.java    |   6 +-
 67 files changed, 1625 insertions(+), 590 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/internals/metrics/ClientMetricsTest.java


Mime
View raw message