Class TenantMetrics.MetricsRequestContext

java.lang.Object

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

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

All Implemented Interfaces:

org.apache.kafka.server.metrics.MetricsBuilderContext

Direct Known Subclasses:

TenantMetrics.ZoneDataMetricsRequestContext

Enclosing class:

TenantMetrics

public static class TenantMetrics.MetricsRequestContext
extends TenantMetrics.TenantMetricsContext

Constructor Summary

Constructors

Constructor	Description
MetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal, String clientId, org.apache.kafka.common.protocol.ApiKeys apiKey)
MetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal, String clientId, org.apache.kafka.common.protocol.ApiKeys apiKey, short apiVersion)
MetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal, String clientId, org.apache.kafka.common.protocol.ApiKeys apiKey, short apiVersion, boolean isFetchFromFollowerEnabled, String networkType)

Method Summary

Modifier and Type	Method	Description
void	addAdditionalTags(Map<String,String> additionalTags)
org.apache.kafka.common.protocol.ApiKeys	apiKey()
String	clientId()
boolean	isFetchFromFollowerEnabled()
boolean	isVersionDeprecated()
Map<String,String>	metricTags()
String	networkType()
String	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

MetricsRequestContext

public MetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
 String clientId,
 org.apache.kafka.common.protocol.ApiKeys apiKey)

MetricsRequestContext

public MetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
 String clientId,
 org.apache.kafka.common.protocol.ApiKeys apiKey,
 short apiVersion)

MetricsRequestContext

public MetricsRequestContext(io.confluent.kafka.multitenant.MultiTenantPrincipal principal,
 String clientId,
 org.apache.kafka.common.protocol.ApiKeys apiKey,
 short apiVersion,
 boolean isFetchFromFollowerEnabled,
 String networkType)

Method Details

clientId

public String clientId()

apiKey

public org.apache.kafka.common.protocol.ApiKeys apiKey()

isVersionDeprecated

public boolean isVersionDeprecated()

isFetchFromFollowerEnabled

public boolean isFetchFromFollowerEnabled()

networkType

public String networkType()

metricTags

public Map<String,String> metricTags()

Specified by:

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

Overrides:

metricTags in class TenantMetrics.TenantMetricsContext

sensorSuffix

public String sensorSuffix()

Specified by:

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

Overrides:

sensorSuffix in class TenantMetrics.TenantMetricsContext

addAdditionalTags

public void addAdditionalTags(Map<String,String> additionalTags)