Class TenantMetrics.ZoneDataMetricsRequestContext

java.lang.Object

io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext

io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

io.confluent.kafka.multitenant.metrics.TenantMetrics.ZoneDataMetricsRequestContext

All Implemented Interfaces:

org.apache.kafka.server.metrics.MetricsBuilderContext

Enclosing class:

TenantMetrics

public static class TenantMetrics.ZoneDataMetricsRequestContext
extends TenantMetrics.MetricsRequestContext

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.

When relevant (e.g. when K2 with XENI is being used), this metrics request context is used for augmenting all TenantMetrics request/response sensors with zone data tags. It adds a tag for the zone ID of each of the aforementioned three layers (client zone ID, gateway (envoy) zone ID, and broker zone ID).

See Also:

• TenantUtils.CLIENT_ZONE_ID_TAG
• TenantUtils.GATEWAY_ZONE_ID_TAG
• TenantUtils.BROKER_ZONE_ID_TAG

Constructor Summary

Constructors

Constructor	Description
ZoneDataMetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal, String clientId, org.apache.kafka.common.protocol.ApiKeys apiKey, short apiVersion, boolean isFetchFromFollowerEnabled, Optional<String> clientZoneId, Optional<String> gatewayZoneId, Optional<String> brokerZoneId, String networkType)

Method Summary

Modifier and Type	Method	Description
Map<String,String>	metricTags()

Methods inherited from class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext

addAdditionalTags, apiKey, clientId, isFetchFromFollowerEnabled, isVersionDeprecated, networkType, sensorSuffix

Methods inherited from class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext

metricsGroup, principal

Methods inherited from class java.lang.Object

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

Constructor Details

ZoneDataMetricsRequestContext

public ZoneDataMetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
 String clientId,
 org.apache.kafka.common.protocol.ApiKeys apiKey,
 short apiVersion,
 boolean isFetchFromFollowerEnabled,
 Optional<String> clientZoneId,
 Optional<String> gatewayZoneId,
 Optional<String> brokerZoneId,
 String networkType)

Method Details

metricTags

public Map<String,String> metricTags()

Specified by:

metricTags in interface org.apache.kafka.server.metrics.MetricsBuilderContext

Overrides:

metricTags in class TenantMetrics.MetricsRequestContext