From ad168b9438cb4f888a82212d4d7793aa2165dd82 Mon Sep 17 00:00:00 2001 From: Dong Lin Date: Wed, 27 May 2015 17:07:05 -0700 Subject: [PATCH] KAFKA-2191; Measured rate should not be infinite --- .../apache/kafka/common/metrics/stats/Rate.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java b/clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java index 98429da..1bf264f 100644 --- a/clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java +++ b/clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java @@ -58,7 +58,8 @@ public class Rate implements MeasurableStat { @Override public double measure(MetricConfig config, long now) { double value = stat.measure(config, now); - double elapsed = convert(now - stat.oldest(now).lastWindowMs); + double elapsed = convert(now - stat.current(now).lastWindowMs + + config.timeWindowMs()*(config.samples()-1)); return value / elapsed; } -- 1.7.9.5