Repository: kafka Updated Branches: refs/heads/trunk 8c551675a -> eb2619cac
MINOR: Fix quota violation exception message Author: Rajini Sivaram <[email protected]> Reviewers: Ismael Juma <[email protected]> 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 <[email protected]> Authored: Thu Jun 16 09:10:59 2016 +0200 Committer: Ismael Juma <[email protected]> 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())); } } }
