Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DOMAIN |
static java.lang.String |
NAMESPACE |
EXCLUDE_ALL
Constructor and Description |
---|
KafkaConnectProvider() |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,?> configs) |
void |
contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
Sets the metrics labels for the service or library exposing metrics.
|
java.lang.String |
domain()
Domain of the active provider.
|
java.util.List<MetricsCollector> |
extraCollectors(Context ctx,
java.util.function.Predicate<MetricKey> metricsPredicate)
The collector for Kafka Metrics library is enabled by default.
|
java.util.List<java.lang.String> |
metricsIncludeRegexDefault()
The metrics include regular expression list used as a default value for this provider.
|
io.opencensus.proto.resource.v1.Resource |
resource()
The resource for this provider.
|
boolean |
validate(org.apache.kafka.common.metrics.MetricsContext metricsContext,
java.util.Map<java.lang.String,?> config)
Validate that all the data required for generating correct metrics is present.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configInclude
public static final java.lang.String DOMAIN
public static final java.lang.String NAMESPACE
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public boolean validate(org.apache.kafka.common.metrics.MetricsContext metricsContext, java.util.Map<java.lang.String,?> config)
Provider
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 java.util.List<java.lang.String> metricsIncludeRegexDefault()
Provider
metricsIncludeRegexDefault
in interface Provider
public io.opencensus.proto.resource.v1.Resource resource()
Provider
public java.lang.String domain()
Provider
public java.util.List<MetricsCollector> extraCollectors(Context ctx, java.util.function.Predicate<MetricKey> metricsPredicate)
Provider
extraCollectors
in interface Provider
ctx
- Context