Package io.confluent.kafka.multitenant.metrics

Class TenantMetrics

java.lang.Object

io.confluent.kafka.multitenant.metrics.TenantMetrics

All Implemented Interfaces:

org.apache.kafka.common.Configurable

public class TenantMetrics
extends Object
implements org.apache.kafka.common.Configurable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TenantMetrics.ApiKeyMetricsContext
static class	TenantMetrics.IpMetricsContext
static class	TenantMetrics.MetricsRequestContext
static class	TenantMetrics.TenantConnectionInformationMetricsContext
static class	TenantMetrics.TenantIpMetricsContext
static class	TenantMetrics.TenantLevelMetricsContext
static class	TenantMetrics.TenantMetricsContext
static class	TenantMetrics.ZoneDataMetricsRequestContext	Starting first with K2's initial Freight offering and XENI, zone alignment between the client, the Confluent-provided gateway into Confluent Cloud, and the serving broker is almost always possible, so it's important to track how exactly the zones of these three layers align.

Constructor Summary

Constructors

Constructor	Description
TenantMetrics()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs)
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	recordClientInformation(org.apache.kafka.common.metrics.Metrics metrics, io.confluent.kafka.multitenant.MultiTenantPrincipal principal, org.apache.kafka.common.network.ClientInformation clientInformation, String clientId, int maxConnectionInfoMetricsPerTenant)
void	recordFailedAuthentication(org.apache.kafka.common.metrics.Metrics metrics, InetAddress clientAddress)
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)
void	setFetchFromFollowerTags(org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.server.metrics.MetricsBuilderContext context, org.apache.kafka.common.protocol.ApiKeys fetchApiKey, io.confluent.kafka.multitenant.ZoneAlignment zoneAlignment, boolean isSupportedFFFClient)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TenantMetrics

public TenantMetrics()

Method Details

recordAuthenticatedConnection

public void recordAuthenticatedConnection(org.apache.kafka.common.metrics.Metrics metrics,
 io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
 InetAddress clientAddress)

recordAuthenticatedDisconnection

public void recordAuthenticatedDisconnection()

recordFailedAuthentication

public void recordFailedAuthentication(org.apache.kafka.common.metrics.Metrics metrics,
 InetAddress clientAddress)

recordClientInformation

public void recordClientInformation(org.apache.kafka.common.metrics.Metrics metrics,
 io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
 org.apache.kafka.common.network.ClientInformation clientInformation,
 String clientId,
 int maxConnectionInfoMetricsPerTenant)

recordRequest

public void recordRequest(org.apache.kafka.common.metrics.Metrics metrics,
 TenantMetrics.MetricsRequestContext context,
 long requestSize,
 long currentTimeMs)

recordResponse

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)

recordPartitionStatsIn

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)

recordPartitionStatsOut

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)

isExpired

public static boolean isExpired(org.apache.kafka.common.metrics.Metrics metrics,
 org.apache.kafka.common.metrics.Sensor sensor)

setFetchFromFollowerTags

public void setFetchFromFollowerTags(org.apache.kafka.common.metrics.Metrics metrics,
 org.apache.kafka.server.metrics.MetricsBuilderContext context,
 org.apache.kafka.common.protocol.ApiKeys fetchApiKey,
 io.confluent.kafka.multitenant.ZoneAlignment zoneAlignment,
 boolean isSupportedFFFClient)

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable