public class TenantMetrics extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TenantMetrics.AggregateTenantMetricsContext
See: CNK-1347
Currently, the request metrics tracked by the metrics API (Telemetry reporter) and what DataDog charts
track internally are not equivalent.
|
static class |
TenantMetrics.MetricsRequestContext |
static class |
TenantMetrics.TenantMetricsContext |
Modifier and Type | Field and Description |
---|---|
static String |
GROUP |
static String |
TENANT_TAG |
Constructor and Description |
---|
TenantMetrics() |
Modifier and Type | Method and Description |
---|---|
static boolean |
isExpired(org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.metrics.Sensor sensor) |
void |
recordAuthenticatedConnection(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal) |
void |
recordAuthenticatedDisconnection() |
void |
recordPartitionStatsIn(org.apache.kafka.common.metrics.Metrics metrics,
TenantMetrics.MetricsRequestContext context,
org.apache.kafka.common.TopicPartition topicPartition,
int size,
int numRecords,
long timeMs) |
void |
recordPartitionStatsOut(org.apache.kafka.common.metrics.Metrics metrics,
TenantMetrics.MetricsRequestContext context,
org.apache.kafka.common.TopicPartition topicPartition,
int size,
int numRecords,
long timeMs) |
void |
recordRequest(org.apache.kafka.common.metrics.Metrics metrics,
TenantMetrics.MetricsRequestContext context,
long requestSize,
long currentTimeMs) |
void |
recordResponse(org.apache.kafka.common.metrics.Metrics metrics,
TenantMetrics.MetricsRequestContext context,
long responseSize,
long responseTimeNanos,
Map<org.apache.kafka.common.protocol.Errors,Integer> errorCounts,
long currentTimeMs) |
public static final String GROUP
public static final String TENANT_TAG
public void recordAuthenticatedConnection(org.apache.kafka.common.metrics.Metrics metrics, MultiTenantPrincipal principal)
public void recordAuthenticatedDisconnection()
public void recordRequest(org.apache.kafka.common.metrics.Metrics metrics, TenantMetrics.MetricsRequestContext context, long requestSize, long currentTimeMs)
public void recordResponse(org.apache.kafka.common.metrics.Metrics metrics, TenantMetrics.MetricsRequestContext context, long responseSize, long responseTimeNanos, Map<org.apache.kafka.common.protocol.Errors,Integer> errorCounts, long currentTimeMs)
public void recordPartitionStatsIn(org.apache.kafka.common.metrics.Metrics metrics, TenantMetrics.MetricsRequestContext context, org.apache.kafka.common.TopicPartition topicPartition, int size, int numRecords, long timeMs)
public void recordPartitionStatsOut(org.apache.kafka.common.metrics.Metrics metrics, TenantMetrics.MetricsRequestContext context, org.apache.kafka.common.TopicPartition topicPartition, int size, int numRecords, long timeMs)
public static boolean isExpired(org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.metrics.Sensor sensor)