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