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/08/25 00:39:16 UTC

[kafka] branch trunk updated (f19cd6c -> 22bcd9f)

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 f19cd6c  KAFKA-10312; Fix error code returned in Metadata response when leader is not available (#9112)
     add 22bcd9f  KAFKA-10054: KIP-613, add TRACE-level e2e latency metrics (#9094)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/admin/AdminClientConfig.java     |   2 +-
 .../kafka/clients/consumer/ConsumerConfig.java     |   2 +-
 .../kafka/clients/producer/ProducerConfig.java     |   2 +-
 .../org/apache/kafka/common/metrics/Sensor.java    |  12 +-
 .../apache/kafka/common/metrics/SensorTest.java    |  59 ++++++--
 .../org/apache/kafka/streams/StreamsConfig.java    |   3 +-
 .../streams/processor/internals/StreamTask.java    |  19 ++-
 .../internals/metrics/ProcessorNodeMetrics.java    |  24 +++
 .../internals/metrics/StreamsMetricsImpl.java      |  10 +-
 .../processor/internals/metrics/TaskMetrics.java   |  28 ----
 .../state/internals/MeteredKeyValueStore.java      |  17 ++-
 .../state/internals/MeteredSessionStore.java       |  13 ++
 .../state/internals/MeteredWindowStore.java        |  11 ++
 .../state/internals/metrics/StateStoreMetrics.java |  25 +++-
 .../integration/MetricsIntegrationTest.java        |  28 +++-
 .../processor/internals/StreamTaskTest.java        | 163 ++++++++++++++++-----
 .../internals/metrics/StreamsMetricsImplTest.java  |  27 +---
 .../internals/metrics/StateStoreMetricsTest.java   |  32 ++++
 18 files changed, 358 insertions(+), 119 deletions(-)