You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/06/16 07:11:08 UTC
kafka git commit: MINOR: Fix quota violation exception message
Repository: kafka
Updated Branches:
refs/heads/trunk 8c551675a -> eb2619cac
MINOR: Fix quota violation exception message
Author: Rajini Sivaram <ra...@googlemail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
Closes #1508 from rajinisivaram/MINOR-quota-exception
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/eb2619ca
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/eb2619ca
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/eb2619ca
Branch: refs/heads/trunk
Commit: eb2619cac0849dd54db956e87781d143a57b2477
Parents: 8c55167
Author: Rajini Sivaram <ra...@googlemail.com>
Authored: Thu Jun 16 09:10:59 2016 +0200
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Thu Jun 16 09:10:59 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/eb2619ca/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()));
}
}
}