kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Fix quota violation exception message
Date Thu, 16 Jun 2016 07:11:35 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 78ac7b6b0 -> 9ba2fdf8b


MINOR: Fix quota violation exception message

Author: Rajini Sivaram <rajinisivaram@googlemail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #1508 from rajinisivaram/MINOR-quota-exception

(cherry picked from commit eb2619cac0849dd54db956e87781d143a57b2477)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9ba2fdf8
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9ba2fdf8
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9ba2fdf8

Branch: refs/heads/0.10.0
Commit: 9ba2fdf8b70da85668966026d41b6fd4b8679108
Parents: 78ac7b6
Author: Rajini Sivaram <rajinisivaram@googlemail.com>
Authored: Thu Jun 16 09:10:59 2016 +0200
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Thu Jun 16 09:11:17 2016 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/kafka/common/metrics/Sensor.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/9ba2fdf8/clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java b/clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
index 098bfa8..3e500d5 100644
--- a/clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
+++ b/clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
@@ -121,10 +121,10 @@ public final class Sensor {
                     double value = metric.value(timeMs);
                     if (!quota.acceptable(value)) {
                         throw new QuotaViolationException(String.format(
-                            "(%s) violated quota. Actual: (%f), Threshold: (%f)",
+                            "'%s' violated quota. Actual: %f, Threshold: %f",
                             metric.metricName(),
-                            quota.bound(),
-                            value));
+                            value,
+                            quota.bound()));
                     }
                 }
             }


Mime
View raw message