public class Sensors
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.metrics.Sensor |
lateRecordDropSensor(InternalProcessorContext context) |
static org.apache.kafka.common.metrics.Sensor |
recordLatenessSensor(InternalProcessorContext context) |
public static org.apache.kafka.common.metrics.Sensor lateRecordDropSensor(InternalProcessorContext context)
public static org.apache.kafka.common.metrics.Sensor recordLatenessSensor(InternalProcessorContext context)