You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/05/27 20:56:10 UTC

[kafka] branch trunk updated (1672a75 -> 83c616f)

This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 1672a75  KAFKA-9724 Newer clients not always sending fetch request to older brokers (#8376)
     add 83c616f  KAFKA-9983: KIP-613: add INFO level e2e latency metrics (#8697)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   2 +
 .../org/apache/kafka/common/metrics/Sensor.java    |   2 +-
 .../kafka/common/metrics/stats/Percentiles.java    |  33 ++++--
 .../kafka/common/metrics/stats/SampledStat.java    |   2 +-
 .../apache/kafka/common/metrics/MetricsTest.java   |  83 ++++++++++++++
 .../processor/internals/ProcessorContextImpl.java  |   3 +
 .../streams/processor/internals/ProcessorNode.java |   4 +
 .../processor/internals/ProcessorTopology.java     |  12 ++
 .../streams/processor/internals/StreamTask.java    |  32 ++++++
 .../internals/metrics/ProcessorNodeMetrics.java    |  30 +++++
 .../internals/metrics/StreamsMetricsImpl.java      |  56 ++++++++++
 .../integration/MetricsIntegrationTest.java        |  10 ++
 .../processor/internals/ActiveTaskCreatorTest.java |   2 +
 .../processor/internals/ProcessorTopologyTest.java |  14 +++
 .../processor/internals/StreamTaskTest.java        | 124 ++++++++++++++++++++-
 .../streams/processor/internals/TaskSuite.java     |   2 +-
 .../metrics/ProcessorNodeMetricsTest.java          |  33 ++++++
 .../internals/metrics/StreamsMetricsImplTest.java  |  42 ++++++-
 .../internals/metrics/TaskMetricsTest.java         |   6 +-
 19 files changed, 470 insertions(+), 22 deletions(-)
 rename streams/src/test/java/org/apache/kafka/streams/{kstream => processor}/internals/metrics/TaskMetricsTest.java (97%)