public class TelemetryReporter
extends java.lang.Object
implements org.apache.kafka.common.metrics.MetricsReporter, org.apache.kafka.common.ClusterResourceListener
Constructor and Description |
---|
TelemetryReporter() |
TelemetryReporter(io.confluent.telemetry.events.EventLoggerFactory<io.confluent.telemetry.events.v1.ConfigEvent> eventLoggerFactory) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Called when the metrics repository is closed.
|
void |
configure(java.util.Map<java.lang.String,?> configs)
Note: we are assuming that these methods are invoked in the following order:
1.
|
void |
contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext) |
java.util.List<MetricsCollector> |
getCollectors() |
void |
init(java.util.List<org.apache.kafka.common.metrics.KafkaMetric> metrics) |
protected static java.util.Map<java.lang.String,java.lang.Object> |
injectProviderConfigs(Provider provider,
java.util.Map<java.lang.String,java.lang.Object> originals) |
void |
metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
This is called whenever a metric is updated or added
|
void |
metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
This is called whenever a metric is removed
|
void |
onUpdate(org.apache.kafka.common.ClusterResource clusterResource) |
java.util.Set<java.lang.String> |
reconfigurableConfigs() |
void |
reconfigure(java.util.Map<java.lang.String,?> configs) |
void |
validateReconfiguration(java.util.Map<java.lang.String,?> configs) |
public TelemetryReporter()
public TelemetryReporter(io.confluent.telemetry.events.EventLoggerFactory<io.confluent.telemetry.events.v1.ConfigEvent> eventLoggerFactory)
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void validateReconfiguration(java.util.Map<java.lang.String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateReconfiguration
in interface org.apache.kafka.common.metrics.MetricsReporter
validateReconfiguration
in interface org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.config.ConfigException
public void reconfigure(java.util.Map<java.lang.String,?> configs)
reconfigure
in interface org.apache.kafka.common.metrics.MetricsReporter
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public java.util.Set<java.lang.String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.metrics.MetricsReporter
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void contextChange(org.apache.kafka.common.metrics.MetricsContext metricsContext)
contextChange
in interface org.apache.kafka.common.metrics.MetricsReporter
public java.util.List<MetricsCollector> getCollectors()
public void close()
close
in interface java.lang.AutoCloseable
close
in interface org.apache.kafka.common.metrics.MetricsReporter
public void onUpdate(org.apache.kafka.common.ClusterResource clusterResource)
onUpdate
in interface org.apache.kafka.common.ClusterResourceListener
public void init(java.util.List<org.apache.kafka.common.metrics.KafkaMetric> metrics)
init
in interface org.apache.kafka.common.metrics.MetricsReporter
public void metricChange(org.apache.kafka.common.metrics.KafkaMetric metric)
metricChange
in interface org.apache.kafka.common.metrics.MetricsReporter
public void metricRemoval(org.apache.kafka.common.metrics.KafkaMetric metric)
metricRemoval
in interface org.apache.kafka.common.metrics.MetricsReporter
protected static java.util.Map<java.lang.String,java.lang.Object> injectProviderConfigs(Provider provider, java.util.Map<java.lang.String,java.lang.Object> originals)