public enum KafkaMetricDef extends Enum<KafkaMetricDef>
KafkaMetricDef.DefScope.BROKER_ONLY
) -- e.g. request queue size.KafkaMetricDef.DefScope.COMMON_PARTITION
and KafkaMetricDef.DefScope.COMMON_REPLICA
)
-- e.g. bytes in/out rate.Modifier and Type | Class and Description |
---|---|
static class |
KafkaMetricDef.DefScope |
public static final KafkaMetricDef CPU_USAGE
public static final KafkaMetricDef DISK_USAGE
public static final KafkaMetricDef LEADER_BYTES_IN
public static final KafkaMetricDef PRODUCER_BYTES_IN
public static final KafkaMetricDef LEADER_BYTES_OUT
public static final KafkaMetricDef PRODUCE_RATE
public static final KafkaMetricDef FETCH_RATE
public static final KafkaMetricDef MESSAGE_IN_RATE
public static final KafkaMetricDef REPLICATION_BYTES_IN_RATE
public static final KafkaMetricDef REPLICATION_BYTES_OUT_RATE
public static final KafkaMetricDef FOLLOWER_FETCH_REQUEST_RATE
public static final KafkaMetricDef FETCH_FROM_FOLLOWER_BYTES_OUT_RATE
public static final KafkaMetricDef FETCH_FROM_FOLLOWER_REQUEST_RATE
public static final KafkaMetricDef BROKER_PRODUCE_REQUEST_RATE
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_REQUEST_RATE
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_REQUEST_RATE
public static final KafkaMetricDef BROKER_REQUEST_QUEUE_SIZE
public static final KafkaMetricDef BROKER_RESPONSE_QUEUE_SIZE
public static final KafkaMetricDef BROKER_PRODUCE_REQUEST_QUEUE_TIME_MS_MAX
public static final KafkaMetricDef BROKER_PRODUCE_REQUEST_QUEUE_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_REQUEST_QUEUE_TIME_MS_MAX
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_REQUEST_QUEUE_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_REQUEST_QUEUE_TIME_MS_MAX
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_REQUEST_QUEUE_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_PRODUCE_TOTAL_TIME_MS_MAX
public static final KafkaMetricDef BROKER_PRODUCE_TOTAL_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_TOTAL_TIME_MS_MAX
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_TOTAL_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_TOTAL_TIME_MS_MAX
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_TOTAL_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_PRODUCE_LOCAL_TIME_MS_MAX
public static final KafkaMetricDef BROKER_PRODUCE_LOCAL_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_LOCAL_TIME_MS_MAX
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_LOCAL_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_LOCAL_TIME_MS_MAX
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_LOCAL_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_LOG_FLUSH_RATE
public static final KafkaMetricDef BROKER_LOG_FLUSH_TIME_MS_MAX
public static final KafkaMetricDef BROKER_LOG_FLUSH_TIME_MS_MEAN
public static final KafkaMetricDef BROKER_PRODUCE_REQUEST_QUEUE_TIME_MS_50TH
public static final KafkaMetricDef BROKER_PRODUCE_REQUEST_QUEUE_TIME_MS_999TH
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_REQUEST_QUEUE_TIME_MS_50TH
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_REQUEST_QUEUE_TIME_MS_999TH
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_REQUEST_QUEUE_TIME_MS_50TH
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_REQUEST_QUEUE_TIME_MS_999TH
public static final KafkaMetricDef BROKER_PRODUCE_TOTAL_TIME_MS_50TH
public static final KafkaMetricDef BROKER_PRODUCE_TOTAL_TIME_MS_999TH
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_TOTAL_TIME_MS_50TH
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_TOTAL_TIME_MS_999TH
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_TOTAL_TIME_MS_50TH
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_TOTAL_TIME_MS_999TH
public static final KafkaMetricDef BROKER_PRODUCE_LOCAL_TIME_MS_50TH
public static final KafkaMetricDef BROKER_PRODUCE_LOCAL_TIME_MS_999TH
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_LOCAL_TIME_MS_50TH
public static final KafkaMetricDef BROKER_CONSUMER_FETCH_LOCAL_TIME_MS_999TH
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_LOCAL_TIME_MS_50TH
public static final KafkaMetricDef BROKER_FOLLOWER_FETCH_LOCAL_TIME_MS_999TH
public static final KafkaMetricDef BROKER_LOG_FLUSH_TIME_MS_50TH
public static final KafkaMetricDef BROKER_LOG_FLUSH_TIME_MS_999TH
public static final KafkaMetricDef BROKER_DISK_CAPACITY
public static KafkaMetricDef[] values()
for (KafkaMetricDef c : KafkaMetricDef.values()) System.out.println(c);
public static KafkaMetricDef valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic ValueComputingStrategy valueComputingStrategy()
public Resource resource()
MetricDef
public static List<KafkaMetricDef> kafkaMetricDefsForRawMetricType(RawMetricType type)
KafkaMetricDef
s associated with the given RawMetricType
public static ValueComputingStrategy valueComputingStrategyForRawMetricType(RawMetricType type)
KafkaMetricDef
associated to the given RawMetricType
.
All metric defs are guaranteed to have the same valueComputingStrategy()
public static short commonMetricDefId(KafkaMetricDef def)
public static short partitionMetricDefId(KafkaMetricDef def)
public static short replicaMetricDefId(KafkaMetricDef def)
public static short metricDefId(MetricDef metricDef, KafkaMetricDef def)
public static MetricDef commonMetricDef()
public static MetricDef brokerMetricDef()
public static MetricDef partitionMetricDef()
public static MetricDef replicaMetricDef()
public static List<MetricInfo> resourceToMetricInfo(Resource resource)
public static List<MetricInfo> resourceToPartitionMetricInfo(Resource resource)