You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by bb...@apache.org on 2019/11/19 18:06:09 UTC
[kafka] branch trunk updated (d046994 -> 19681f6)

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 d046994  KAFKA-8981 Add rate limiting to NetworkDegradeSpec (#7446)
     add 19681f6  KAFKA-9086: Refactor processor-node-level metrics (#7615)

No new revisions were added by this update.

Summary of changes:
 .../internals/KStreamSessionWindowAggregate.java   |  14 +-
 .../kstream/internals/KStreamWindowAggregate.java  |  16 +-
 .../streams/kstream/internals/metrics/Sensors.java |  93 -----
 .../suppress/KTableSuppressProcessorSupplier.java  |   9 +-
 .../streams/processor/internals/ProcessorNode.java | 187 +++------
 .../streams/processor/internals/SourceNode.java    |  11 +-
 .../streams/processor/internals/StreamTask.java    |  29 +-
 .../streams/processor/internals/StreamThread.java  |   7 +-
 .../internals/metrics/ProcessorNodeMetrics.java    | 420 +++++++++++++++++++++
 .../internals/metrics/StreamsMetricsImpl.java      |   6 +-
 .../processor/internals/metrics/TaskMetrics.java   |  12 +-
 .../processor/internals/metrics/ThreadMetrics.java |  72 ++--
 .../state/internals/metrics/StateStoreMetrics.java |   1 -
 .../integration/MetricsIntegrationTest.java        |  91 ++---
 ...KStreamSessionWindowAggregateProcessorTest.java | 224 ++++++-----
 .../internals/KStreamWindowAggregateTest.java      | 162 +++++---
 .../kstream/internals/metrics/TaskMetricsTest.java |  34 +-
 .../KTableSuppressProcessorMetricsTest.java        |  12 +-
 .../processor/internals/ProcessorNodeTest.java     | 107 +++---
 .../processor/internals/SourceNodeTest.java        |  59 +++
 .../metrics/ProcessorNodeMetricsTest.java          | 383 +++++++++++++++++++
 .../internals/metrics/StreamsMetricsImplTest.java  |  26 +-
 .../internals/metrics/ThreadMetricsTest.java       |  56 ++-
 .../kafka/test/InternalMockProcessorContext.java   |  12 +
 .../org/apache/kafka/test/StreamsTestUtils.java    |   9 +
 25 files changed, 1466 insertions(+), 586 deletions(-)
 delete mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/metrics/Sensors.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest.java