Class RemoteStorageMetrics

java.lang.Object
org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics

public class RemoteStorageMetrics extends Object
This class contains the metrics related to tiered storage feature, which is to have a centralized place to store them, so that we can verify all of them easily.
See Also:
  • kafka.api.MetricsTest
  • Field Details

    • REMOTE_STORAGE_THREAD_POOL_METRICS

      public static final Set<String> REMOTE_STORAGE_THREAD_POOL_METRICS
    • REMOTE_COPY_BYTES_PER_SEC_METRIC

      public static final com.yammer.metrics.core.MetricName REMOTE_COPY_BYTES_PER_SEC_METRIC
    • REMOTE_FETCH_BYTES_PER_SEC_METRIC

      public static final com.yammer.metrics.core.MetricName REMOTE_FETCH_BYTES_PER_SEC_METRIC
    • REMOTE_FETCH_REQUESTS_PER_SEC_METRIC

      public static final com.yammer.metrics.core.MetricName REMOTE_FETCH_REQUESTS_PER_SEC_METRIC
    • REMOTE_COPY_REQUESTS_PER_SEC_METRIC

      public static final com.yammer.metrics.core.MetricName REMOTE_COPY_REQUESTS_PER_SEC_METRIC
    • FAILED_REMOTE_FETCH_PER_SEC_METRIC

      public static final com.yammer.metrics.core.MetricName FAILED_REMOTE_FETCH_PER_SEC_METRIC
    • FAILED_REMOTE_COPY_PER_SEC_METRIC

      public static final com.yammer.metrics.core.MetricName FAILED_REMOTE_COPY_PER_SEC_METRIC
    • REMOTE_LOG_MANAGER_TASKS_AVG_IDLE_PERCENT_METRIC

      public static final com.yammer.metrics.core.MetricName REMOTE_LOG_MANAGER_TASKS_AVG_IDLE_PERCENT_METRIC
    • REMOTE_LOG_READER_TASK_QUEUE_SIZE_METRIC

      public static final com.yammer.metrics.core.MetricName REMOTE_LOG_READER_TASK_QUEUE_SIZE_METRIC
    • REMOTE_LOG_READER_AVG_IDLE_PERCENT_METRIC

      public static final com.yammer.metrics.core.MetricName REMOTE_LOG_READER_AVG_IDLE_PERCENT_METRIC
  • Constructor Details

    • RemoteStorageMetrics

      public RemoteStorageMetrics()
  • Method Details

    • allMetrics

      public static Set<com.yammer.metrics.core.MetricName> allMetrics()
    • brokerTopicStatsMetrics

      public static Set<com.yammer.metrics.core.MetricName> brokerTopicStatsMetrics()