io.confluent.telemetry.emitter

Class ClientMetricsTelemetryReceiver

java.lang.Object

io.confluent.telemetry.emitter.ClientMetricsTelemetryReceiver

All Implemented Interfaces:

org.apache.kafka.server.telemetry.ClientTelemetryReceiver

public class ClientMetricsTelemetryReceiver
extends Object
implements org.apache.kafka.server.telemetry.ClientTelemetryReceiver

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	exportMetrics(org.apache.kafka.server.authorizer.AuthorizableRequestContext authCtx, org.apache.kafka.server.telemetry.ClientTelemetryPayload payload)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientMetricsTelemetryReceiver

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

Method Detail

exportMetrics

public void exportMetrics(org.apache.kafka.server.authorizer.AuthorizableRequestContext authCtx,
                          org.apache.kafka.server.telemetry.ClientTelemetryPayload payload)

Specified by:

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