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.TenantIpMetricsContext |
static class |
TenantMetrics.TenantMetricsContext |
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,
io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
InetAddress clientAddress) |
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 void recordAuthenticatedConnection(org.apache.kafka.common.metrics.Metrics metrics, io.confluent.kafka.multitenant.MultiTenantPrincipal principal, InetAddress clientAddress)
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)