Class ClientMetricsTelemetryExporter

java.lang.Object

io.confluent.telemetry.emitter.ClientMetricsTelemetryExporter

All Implemented Interfaces:

org.apache.kafka.server.telemetry.ClientTelemetryExporter

public class ClientMetricsTelemetryExporter
extends Object
implements org.apache.kafka.server.telemetry.ClientTelemetryExporter

ClientMetricsTelemetryExporter implements the ClientTelemetryExporter interface to receive client telemetry metrics, augment them with additional labels, and emit them using a provided telemetry emitter.

Constructor Summary

Constructors

Constructor	Description
ClientMetricsTelemetryExporter(TelemetryEmitter emitter, Context context, Map<String,String> contextLabels, Set<String> excludeLabels)

Method Summary

Modifier and Type	Method	Description
void	exportMetrics(org.apache.kafka.server.telemetry.ClientTelemetryContext telemetryContext, org.apache.kafka.server.telemetry.ClientTelemetryPayload payload)

Methods inherited from class Object

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

Constructor Details

ClientMetricsTelemetryExporter

public ClientMetricsTelemetryExporter(TelemetryEmitter emitter,
 Context context,
 Map<String,String> contextLabels,
 Set<String> excludeLabels)

Method Details

exportMetrics

public void exportMetrics(org.apache.kafka.server.telemetry.ClientTelemetryContext telemetryContext,
 org.apache.kafka.server.telemetry.ClientTelemetryPayload payload)

Specified by:

exportMetrics in interface org.apache.kafka.server.telemetry.ClientTelemetryExporter