Package org.apache.kafka.clients.consumer.internals

Class FetchMetricsRegistry

java.lang.Object
org.apache.kafka.clients.consumer.internals.FetchMetricsRegistry
public class FetchMetricsRegistry extends Object

  • Field Details

    • fetchSizeAvg

      public org.apache.kafka.common.MetricNameTemplate fetchSizeAvg

    • fetchSizeMax

      public org.apache.kafka.common.MetricNameTemplate fetchSizeMax

    • bytesConsumedRate

      public org.apache.kafka.common.MetricNameTemplate bytesConsumedRate

    • bytesConsumedTotal

      public org.apache.kafka.common.MetricNameTemplate bytesConsumedTotal

    • recordsPerRequestAvg

      public org.apache.kafka.common.MetricNameTemplate recordsPerRequestAvg

    • recordsConsumedRate

      public org.apache.kafka.common.MetricNameTemplate recordsConsumedRate

    • recordsConsumedTotal

      public org.apache.kafka.common.MetricNameTemplate recordsConsumedTotal

    • fetchLatencyAvg

      public org.apache.kafka.common.MetricNameTemplate fetchLatencyAvg

    • fetchLatencyMax

      public org.apache.kafka.common.MetricNameTemplate fetchLatencyMax

    • fetchRequestRate

      public org.apache.kafka.common.MetricNameTemplate fetchRequestRate

    • fetchRequestTotal

      public org.apache.kafka.common.MetricNameTemplate fetchRequestTotal

    • recordsLagMax

      public org.apache.kafka.common.MetricNameTemplate recordsLagMax

    • recordsLeadMin

      public org.apache.kafka.common.MetricNameTemplate recordsLeadMin

    • fetchThrottleTimeAvg

      public org.apache.kafka.common.MetricNameTemplate fetchThrottleTimeAvg

    • fetchThrottleTimeMax

      public org.apache.kafka.common.MetricNameTemplate fetchThrottleTimeMax

    • topicFetchSizeAvg

      public org.apache.kafka.common.MetricNameTemplate topicFetchSizeAvg

    • topicFetchSizeMax

      public org.apache.kafka.common.MetricNameTemplate topicFetchSizeMax

    • topicBytesConsumedRate

      public org.apache.kafka.common.MetricNameTemplate topicBytesConsumedRate

    • topicBytesConsumedTotal

      public org.apache.kafka.common.MetricNameTemplate topicBytesConsumedTotal

    • topicRecordsPerRequestAvg

      public org.apache.kafka.common.MetricNameTemplate topicRecordsPerRequestAvg

    • topicRecordsConsumedRate

      public org.apache.kafka.common.MetricNameTemplate topicRecordsConsumedRate

    • topicRecordsConsumedTotal

      public org.apache.kafka.common.MetricNameTemplate topicRecordsConsumedTotal

    • partitionRecordsLag

      public org.apache.kafka.common.MetricNameTemplate partitionRecordsLag

    • partitionRecordsLagMax

      public org.apache.kafka.common.MetricNameTemplate partitionRecordsLagMax

    • partitionRecordsLagAvg

      public org.apache.kafka.common.MetricNameTemplate partitionRecordsLagAvg

    • partitionRecordsLead

      public org.apache.kafka.common.MetricNameTemplate partitionRecordsLead

    • partitionRecordsLeadMin

      public org.apache.kafka.common.MetricNameTemplate partitionRecordsLeadMin

    • partitionRecordsLeadAvg

      public org.apache.kafka.common.MetricNameTemplate partitionRecordsLeadAvg

    • partitionPreferredReadReplica

      public org.apache.kafka.common.MetricNameTemplate partitionPreferredReadReplica

  • Constructor Details

    • FetchMetricsRegistry

      public FetchMetricsRegistry()

    • FetchMetricsRegistry

      public FetchMetricsRegistry(String metricGrpPrefix)

    • FetchMetricsRegistry

      public FetchMetricsRegistry(Set<String> tags, String metricGrpPrefix)

  • Method Details

    • getAllTemplates

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