public class ConnectionSensorBuilder extends org.apache.kafka.server.metrics.AbstractSensorBuilder<TenantMetrics.TenantMetricsContext,ConnectionSensors>
Constructor and Description |
---|
ConnectionSensorBuilder(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal) |
Modifier and Type | Method and Description |
---|---|
ConnectionSensors |
build() |
protected <T> org.apache.kafka.common.metrics.Sensor |
createSensor(java.util.Map<T,? extends org.apache.kafka.server.metrics.AbstractSensorCreator> sensorCreators,
T sensorKey,
java.lang.String sensorName) |
protected java.util.Map<java.lang.String,? extends org.apache.kafka.server.metrics.AbstractSensorCreator> |
sensorCreators() |
protected java.lang.String |
sensorSuffix(java.lang.String unused,
TenantMetrics.TenantMetricsContext context) |
public ConnectionSensorBuilder(org.apache.kafka.common.metrics.Metrics metrics, MultiTenantPrincipal principal)
public ConnectionSensors build()
build
in class org.apache.kafka.server.metrics.AbstractSensorBuilder<TenantMetrics.TenantMetricsContext,ConnectionSensors>
protected <T> org.apache.kafka.common.metrics.Sensor createSensor(java.util.Map<T,? extends org.apache.kafka.server.metrics.AbstractSensorCreator> sensorCreators, T sensorKey, java.lang.String sensorName)
createSensor
in class org.apache.kafka.server.metrics.AbstractSensorBuilder<TenantMetrics.TenantMetricsContext,ConnectionSensors>
protected java.lang.String sensorSuffix(java.lang.String unused, TenantMetrics.TenantMetricsContext context)
sensorSuffix
in class org.apache.kafka.server.metrics.AbstractSensorBuilder<TenantMetrics.TenantMetricsContext,ConnectionSensors>
protected java.util.Map<java.lang.String,? extends org.apache.kafka.server.metrics.AbstractSensorCreator> sensorCreators()
sensorCreators
in class org.apache.kafka.server.metrics.AbstractSensorBuilder<TenantMetrics.TenantMetricsContext,ConnectionSensors>