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 (121c769 -> 353aa62)
Date Tue, 31 Mar 2020 23:40:11 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 121c769  MINOR: Fix MockAdminClient to not throw IndexOutOfBoundsException when brokerId
is above the known one. (#8392)
     add 353aa62  KAFKA-9753: Add active tasks process ratio (#8370)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/StreamTask.java    | 16 +++++
 .../streams/processor/internals/StreamThread.java  | 13 +++-
 .../kafka/streams/processor/internals/Task.java    |  4 ++
 .../streams/processor/internals/TaskManager.java   | 13 +++-
 .../processor/internals/metrics/TaskMetrics.java   | 21 ++++++
 .../processor/internals/metrics/ThreadMetrics.java | 63 ++++++++--------
 .../integration/QueryableStateIntegrationTest.java | 20 ++----
 .../kstream/internals/metrics/TaskMetricsTest.java | 24 +++++++
 .../processor/internals/StreamTaskTest.java        | 27 ++++++-
 .../processor/internals/StreamThreadTest.java      |  9 +++
 .../processor/internals/TaskManagerTest.java       | 12 ++--
 .../internals/metrics/ThreadMetricsTest.java       | 84 ++++++++++++++++++++++
 12 files changed, 247 insertions(+), 59 deletions(-)


Mime
View raw message