Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_BROKER_METRICS_INCLUDE_REGEX |
static String |
DEFAULT_SECURITY_METRICS_INCLUDE_REGEX |
static String |
LABEL_BROKER_ID |
static String |
LABEL_BROKER_RACK |
static String |
LABEL_CELL_ID |
static String |
LABEL_CLUSTER_ID |
static String |
LABEL_PROCESS_BROKER |
static String |
LABEL_PROCESS_CONTROLLER |
static String |
LABEL_PROCESS_ROLES |
static String |
NAMESPACE |
EXCLUDE_ALL
Constructor and Description |
---|
KafkaServerProvider() |
Modifier and Type | Method and Description |
---|---|
Predicate<String> |
configInclude()
Include list for config
|
void |
configure(Map<String,?> configs) |
void |
contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
Sets the metrics labels for the service or library exposing metrics.
|
String |
domain()
Domain of the active provider.
|
List<MetricsCollector> |
extraCollectors(Context ctx)
The collector for Kafka Metrics library is enabled by default.
|
List<String> |
metricsIncludeRegexDefault()
The metrics include regular expression list used as a default value for this provider.
|
io.opentelemetry.proto.resource.v1.Resource |
resource()
The resource for this provider.
|
boolean |
validate(org.apache.kafka.common.metrics.MetricsContext metricsContext,
Map<String,?> config)
Validate that all the data required for generating correct metrics is present.
|
public static final String DEFAULT_SECURITY_METRICS_INCLUDE_REGEX
public static final String DEFAULT_BROKER_METRICS_INCLUDE_REGEX
public static final String LABEL_CLUSTER_ID
public static final String LABEL_BROKER_ID
public static final String LABEL_BROKER_RACK
public static final String LABEL_CELL_ID
public static final String LABEL_PROCESS_ROLES
public static final String LABEL_PROCESS_BROKER
public static final String LABEL_PROCESS_CONTROLLER
public static final String NAMESPACE
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public io.opentelemetry.proto.resource.v1.Resource resource()
Provider
public boolean validate(org.apache.kafka.common.metrics.MetricsContext metricsContext, Map<String,?> config)
Provider
public String domain()
Provider
public List<MetricsCollector> extraCollectors(Context ctx)
Provider
extraCollectors
in interface Provider
ctx
- Context
public void contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
Provider
MetricsReporter.init(List)
and may be called anytime after that.contextChange
in interface Provider
metricsContext
- MetricsContext
public List<String> metricsIncludeRegexDefault()
Provider
metricsIncludeRegexDefault
in interface Provider
public Predicate<String> configInclude()
Provider
configInclude
in interface Provider