public enum KafkaMetricDef extends java.lang.Enum<KafkaMetricDef>
KafkaMetricDef.DefScope.BROKER_ONLY
) -- e.g. request queue size.KafkaMetricDef.DefScope.COMMON
) -- e.g. bytes in/out rate.Modifier and Type | Class and Description |
---|---|
static class |
KafkaMetricDef.DefScope |
Modifier and Type | Method and Description |
---|---|
static MetricDef |
brokerMetricDef() |
static java.util.List<KafkaMetricDef> |
cachedBrokerDefValues() |
static java.util.List<KafkaMetricDef> |
cachedCommonDefValues() |
static MetricDef |
commonMetricDef() |
static short |
commonMetricDefId(KafkaMetricDef def) |
static MetricInfo |
commonMetricDefInfo(KafkaMetricDef def) |
KafkaMetricDef.DefScope |
defScope() |
static KafkaMetricDef |
forRawMetricType(RawMetricType type) |
java.lang.String |
group()
The metric group of the Kafka metric def.
|
static java.util.List<java.lang.Short> |
resourceToMetricIds(Resource resource) |
static java.util.List<MetricInfo> |
resourceToMetricInfo(Resource resource) |
ValueComputingStrategy |
valueComputingStrategy() |
static KafkaMetricDef |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static KafkaMetricDef[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final KafkaMetricDef CPU_USAGE
public static final KafkaMetricDef DISK_USAGE
public static final KafkaMetricDef LEADER_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 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_HANDLER_POOL_IDLE_PERCENT
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(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is nullpublic ValueComputingStrategy valueComputingStrategy()
public KafkaMetricDef.DefScope defScope()
public java.lang.String group()
MetricDef
public static java.util.List<KafkaMetricDef> cachedCommonDefValues()
public static java.util.List<KafkaMetricDef> cachedBrokerDefValues()
public static KafkaMetricDef forRawMetricType(RawMetricType type)
public static short commonMetricDefId(KafkaMetricDef def)
public static MetricInfo commonMetricDefInfo(KafkaMetricDef def)
public static MetricDef commonMetricDef()
public static MetricDef brokerMetricDef()
public static java.util.List<MetricInfo> resourceToMetricInfo(Resource resource)
public static java.util.List<java.lang.Short> resourceToMetricIds(Resource resource)