Package org.apache.kafka.server.telemetry

Interface ClientTelemetryReceiver

@Evolving public interface ClientTelemetryReceiver
ClientTelemetryReceiver defines the behaviour for telemetry receiver on the broker side which receives client telemetry metrics.

  • Method Details

    • exportMetrics

      void exportMetrics(AuthorizableRequestContext context, ClientTelemetryPayload payload)
      Called by the broker when a client reports telemetry metrics. The associated request context can be used by the metrics plugin to retrieve additional client information such as client ids or endpoints.

      This method may be called from the request handling thread, and as such should avoid blocking.

      Parameters:
      context - the client request context for the corresponding PushTelemetryRequest api call.
      payload - the encoded telemetry payload as sent by the client.