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	Description
ClientMetricsTelemetryReceiver(TelemetryEmitter emitter, Context context, Map<String,String> contextLabels, Set<String> excludeLabels)

Method Summary

Modifier and Type	Method	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 Details

ClientMetricsTelemetryReceiver

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

Method Details

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