public abstract class AbstractSensorBuilder<C,S>
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected C |
context |
protected org.apache.kafka.common.metrics.Metrics |
metrics |
Constructor and Description |
---|
AbstractSensorBuilder(org.apache.kafka.common.metrics.Metrics metrics,
C context) |
Modifier and Type | Method and Description |
---|---|
abstract S |
build()
Returns an object which provides a way to record values in the sensors
|
protected abstract java.util.Map<java.lang.String,? extends AbstractSensorCreator> |
sensorCreators() |
protected abstract java.lang.String |
sensorSuffix(java.lang.String name,
C context) |
protected final org.apache.kafka.common.metrics.Metrics metrics
protected final C context
public AbstractSensorBuilder(org.apache.kafka.common.metrics.Metrics metrics, C context)
metrics
- the metrics registry tocontext
- the context in which to create the metrics
used to uniquely identify sensors and metrics across different contexts
(e.g. for tenant level metrics, this could be a MultitenantPrincipal)public abstract S build()
protected abstract java.lang.String sensorSuffix(java.lang.String name, C context)
protected abstract java.util.Map<java.lang.String,? extends AbstractSensorCreator> sensorCreators()