Browse Source

KAFKA-1498 Follow-up: add metric on avg record size.

pull/28/head
Jay Kreps 11 years ago
parent
commit
e3dfad304e
  1. 1
      clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java

1
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java

@ -343,6 +343,7 @@ public class Sender implements Runnable { @@ -343,6 +343,7 @@ public class Sender implements Runnable {
this.maxRecordSizeSensor = metrics.sensor("record-size-max");
this.maxRecordSizeSensor.add("record-size-max", "The maximum record size", new Max());
this.maxRecordSizeSensor.add("record-size-avg", "The average record size", new Avg());
this.metrics.addMetric("requests-in-flight", "The current number of in-flight requests awaiting a response.", new Measurable() {
public double measure(MetricConfig config, long now) {

Loading…
Cancel
Save