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

Posted to commits@kafka.apache.org by gu...@apache.org on 2020/04/06 22:31:21 UTC

[kafka] branch trunk updated (712ac52 -> 82dff1d)

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 712ac52  KAFKA-9793: Expand the try-catch for task commit in HandleAssignment (#8402)
     add 82dff1d  KAFKA-9753: A few more metrics to add (#8371)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  15 +-
 .../streams/internals/metrics/ClientMetrics.java   |  12 ++
 .../streams/processor/internals/StreamTask.java    |   5 +-
 .../streams/processor/internals/StreamThread.java  |  13 +-
 .../kafka/streams/processor/internals/Task.java    |   2 +-
 .../streams/processor/internals/TaskManager.java   |   2 +-
 .../internals/metrics/StreamsMetricsImpl.java      |   1 +
 .../processor/internals/metrics/TaskMetrics.java   |  20 +-
 .../processor/internals/metrics/ThreadMetrics.java |  39 ++++
 .../org/apache/kafka/streams/KafkaStreamsTest.java |   1 +
 .../integration/MetricsIntegrationTest.java        | 106 +++++-----
 .../internals/metrics/ClientMetricsTest.java       |  45 +++-
 .../kstream/internals/metrics/TaskMetricsTest.java |  24 +++
 .../processor/internals/StreamTaskTest.java        |  49 ++++-
 .../processor/internals/StreamThreadTest.java      |  24 ++-
 .../internals/metrics/ThreadMetricsTest.java       | 230 +++++++++++++--------
 16 files changed, 418 insertions(+), 170 deletions(-)