io.confluent.telemetry.emitter

Class TelemetryEmitter

java.lang.Object

io.confluent.telemetry.emitter.TelemetryEmitter

All Implemented Interfaces:

Emitter

public class TelemetryEmitter
extends Object
implements Emitter

Must construct after 1. TelemetryReporter.configure(java.util.Map<java.lang.String, ?>) [must be called first & only once] 2. TelemetryReporter.contextChange(org.apache.kafka.common.metrics.MetricsContext) [must be called second]

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
TelemetryEmitter(Context context, Supplier<Collection<Exporter>> exportersSupplier, org.apache.kafka.common.metrics.Metrics metrics)

Method Summary

Modifier and Type	Method and Description
boolean	emitMetric(ExportableMetric exportableMetric)
boolean	emitMetric(SinglePointMetric metric) Emits a metric to all configured Exporter objects.
void	reconfigurePredicate(Predicate<? super Keyed> metricsPredicate)
boolean	shouldEmitMetric(Keyed key) Tests whether this metric object could actually be emitted based on its key.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.telemetry.emitter.Emitter

maybeEmitMetric

Field Detail

log

public static final org.slf4j.Logger log

Constructor Detail

TelemetryEmitter

public TelemetryEmitter(Context context,
                        Supplier<Collection<Exporter>> exportersSupplier,
                        org.apache.kafka.common.metrics.Metrics metrics)

Method Detail

shouldEmitMetric

public boolean shouldEmitMetric(Keyed key)

Description copied from interface: Emitter

Tests whether this metric object could actually be emitted based on its key. This is useful when materializing the metric object is an expensive operation.

Specified by:

shouldEmitMetric in interface Emitter

Parameters:

key - metric key to test against

Returns:

true if it is possible for this object to get emitted, false otherwise

emitMetric

public boolean emitMetric(SinglePointMetric metric)

Description copied from interface: Emitter

Emits a metric to all configured Exporter objects.

Specified by:

emitMetric in interface Emitter

Parameters:

metric - to emit

Returns:

true if exported by at least one exporter, false otherwise

emitMetric

public boolean emitMetric(ExportableMetric exportableMetric)

reconfigurePredicate

public void reconfigurePredicate(Predicate<? super Keyed> metricsPredicate)