public class ApiSensorBuilder extends AbstractSensorBuilder<ApiSensors>
Modifier and Type | Field and Description |
---|---|
static long |
EXPIRY_SECONDS |
metrics, principal
Constructor and Description |
---|
ApiSensorBuilder(org.apache.kafka.common.metrics.Metrics metrics,
MultiTenantPrincipal principal,
org.apache.kafka.common.protocol.ApiKeys apiKey) |
Modifier and Type | Method and Description |
---|---|
void |
addErrorSensors(ApiSensors apiSensors,
java.util.Set<org.apache.kafka.common.protocol.Errors> errors) |
ApiSensors |
build()
Returns an object which provides a way to record values in the sensors
|
protected java.util.Map<java.lang.String,? extends AbstractSensorCreator> |
sensorCreators() |
protected java.lang.String |
sensorSuffix(java.lang.String unused,
MultiTenantPrincipal principal) |
public ApiSensorBuilder(org.apache.kafka.common.metrics.Metrics metrics, MultiTenantPrincipal principal, org.apache.kafka.common.protocol.ApiKeys apiKey)
public ApiSensors build()
AbstractSensorBuilder
build
in class AbstractSensorBuilder<ApiSensors>
protected java.lang.String sensorSuffix(java.lang.String unused, MultiTenantPrincipal principal)
sensorSuffix
in class AbstractSensorBuilder<ApiSensors>
protected java.util.Map<java.lang.String,? extends AbstractSensorCreator> sensorCreators()
sensorCreators
in class AbstractSensorBuilder<ApiSensors>
public void addErrorSensors(ApiSensors apiSensors, java.util.Set<org.apache.kafka.common.protocol.Errors> errors)