Class DeprecatedRequestSensors
java.lang.Object
io.confluent.kafka.multitenant.metrics.DeprecatedRequestSensors
Per-connection manager for deprecated request metric and its quota. This class is thread-safe.
-
Constructor Summary
ConstructorsConstructorDescriptionDeprecatedRequestSensors(org.apache.kafka.common.metrics.Metrics metrics, io.confluent.kafka.multitenant.MultiTenantPrincipal principal, org.apache.kafka.common.protocol.ApiKeys apiKey, String clientId, int maxDeprecatedRequestMetricsPerTenant) -
Method Summary
Modifier and TypeMethodDescriptionvoidRecord a received deprecated request.
-
Constructor Details
-
DeprecatedRequestSensors
public DeprecatedRequestSensors(org.apache.kafka.common.metrics.Metrics metrics, io.confluent.kafka.multitenant.MultiTenantPrincipal principal, org.apache.kafka.common.protocol.ApiKeys apiKey, String clientId, int maxDeprecatedRequestMetricsPerTenant)
-
-
Method Details
-
recordDeprecatedRequest
public void recordDeprecatedRequest()Record a received deprecated request. Deprecation of requests are defined in theApiKeys.isVersionDeprecated(short)method. The number of unique deprecated request metrics is subject to a per-tenant cap to prevent memory exhaustion.
-