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, Map<String,String> contextLabels)

Method Summary

Modifier and Type	Method and Description
void	exportMetrics(org.apache.kafka.server.authorizer.AuthorizableRequestContext context, 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,
                                      Map<String,String> contextLabels)

Method Detail

exportMetrics

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

Specified by:

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