public class TenantMetrics
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TENANT_TAG |
Constructor and Description |
---|
TenantMetrics() |
Modifier and Type | Method and Description |
---|---|
void |
recordAuthenticatedConnection(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal) |
void |
recordAuthenticatedDisconnection() |
void |
recordPartitionBytesIn(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal,
org.apache.kafka.common.TopicPartition topicPartition,
int size) |
void |
recordPartitionBytesOut(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal,
org.apache.kafka.common.TopicPartition topicPartition,
int size) |
void |
recordRequest(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal,
org.apache.kafka.common.protocol.ApiKeys apiKey,
long requestSize) |
void |
recordResponse(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal,
org.apache.kafka.common.protocol.ApiKeys apiKey,
long responseSize,
long responseTimeNanos,
java.util.Map<org.apache.kafka.common.protocol.Errors,java.lang.Integer> errorCounts) |
public static final java.lang.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, MultiTenantPrincipal principal, org.apache.kafka.common.protocol.ApiKeys apiKey, long requestSize)
public void recordResponse(org.apache.kafka.common.metrics.Metrics metrics, MultiTenantPrincipal principal, org.apache.kafka.common.protocol.ApiKeys apiKey, long responseSize, long responseTimeNanos, java.util.Map<org.apache.kafka.common.protocol.Errors,java.lang.Integer> errorCounts)
public void recordPartitionBytesIn(org.apache.kafka.common.metrics.Metrics metrics, MultiTenantPrincipal principal, org.apache.kafka.common.TopicPartition topicPartition, int size)
public void recordPartitionBytesOut(org.apache.kafka.common.metrics.Metrics metrics, MultiTenantPrincipal principal, org.apache.kafka.common.TopicPartition topicPartition, int size)