Package org.apache.kafka.clients.producer.internals

Class SenderMetricsRegistry

java.lang.Object
org.apache.kafka.clients.producer.internals.SenderMetricsRegistry
public class SenderMetricsRegistry extends Object

  • Field Details

    • batchSizeAvg

      public final org.apache.kafka.common.MetricName batchSizeAvg

    • batchSizeMax

      public final org.apache.kafka.common.MetricName batchSizeMax

    • compressionRateAvg

      public final org.apache.kafka.common.MetricName compressionRateAvg

    • recordQueueTimeAvg

      public final org.apache.kafka.common.MetricName recordQueueTimeAvg

    • recordQueueTimeMax

      public final org.apache.kafka.common.MetricName recordQueueTimeMax

    • requestLatencyAvg

      public final org.apache.kafka.common.MetricName requestLatencyAvg

    • requestLatencyMax

      public final org.apache.kafka.common.MetricName requestLatencyMax

    • produceThrottleTimeAvg

      public final org.apache.kafka.common.MetricName produceThrottleTimeAvg

    • produceThrottleTimeMax

      public final org.apache.kafka.common.MetricName produceThrottleTimeMax

    • recordSendRate

      public final org.apache.kafka.common.MetricName recordSendRate

    • recordSendTotal

      public final org.apache.kafka.common.MetricName recordSendTotal

    • recordsPerRequestAvg

      public final org.apache.kafka.common.MetricName recordsPerRequestAvg

    • recordRetryRate

      public final org.apache.kafka.common.MetricName recordRetryRate

    • recordRetryTotal

      public final org.apache.kafka.common.MetricName recordRetryTotal

    • recordErrorRate

      public final org.apache.kafka.common.MetricName recordErrorRate

    • recordErrorTotal

      public final org.apache.kafka.common.MetricName recordErrorTotal

    • recordSizeMax

      public final org.apache.kafka.common.MetricName recordSizeMax

    • recordSizeAvg

      public final org.apache.kafka.common.MetricName recordSizeAvg

    • requestsInFlight

      public final org.apache.kafka.common.MetricName requestsInFlight

    • metadataAge

      public final org.apache.kafka.common.MetricName metadataAge

    • batchSplitRate

      public final org.apache.kafka.common.MetricName batchSplitRate

    • batchSplitTotal

      public final org.apache.kafka.common.MetricName batchSplitTotal

  • Constructor Details

    • SenderMetricsRegistry

      public SenderMetricsRegistry(org.apache.kafka.common.metrics.Metrics metrics)

  • Method Details

    • topicRecordSendRate

      public org.apache.kafka.common.MetricName topicRecordSendRate(Map<String,String> tags)

    • topicRecordSendTotal

      public org.apache.kafka.common.MetricName topicRecordSendTotal(Map<String,String> tags)

    • topicByteRate

      public org.apache.kafka.common.MetricName topicByteRate(Map<String,String> tags)

    • topicByteTotal

      public org.apache.kafka.common.MetricName topicByteTotal(Map<String,String> tags)

    • topicCompressionRate

      public org.apache.kafka.common.MetricName topicCompressionRate(Map<String,String> tags)

    • topicRecordRetryRate

      public org.apache.kafka.common.MetricName topicRecordRetryRate(Map<String,String> tags)

    • topicRecordRetryTotal

      public org.apache.kafka.common.MetricName topicRecordRetryTotal(Map<String,String> tags)

    • topicRecordErrorRate

      public org.apache.kafka.common.MetricName topicRecordErrorRate(Map<String,String> tags)

    • topicRecordErrorTotal

      public org.apache.kafka.common.MetricName topicRecordErrorTotal(Map<String,String> tags)

    • allTemplates

      public List<org.apache.kafka.common.MetricNameTemplate> allTemplates()

    • sensor

      public org.apache.kafka.common.metrics.Sensor sensor(String name)

    • addMetric

      public void addMetric(org.apache.kafka.common.MetricName m, org.apache.kafka.common.metrics.Measurable measurable)

    • getSensor

      public org.apache.kafka.common.metrics.Sensor getSensor(String name)