Class Sensors


  • public class Sensors
    extends java.lang.Object
    • Method Detail

      • lateRecordDropSensor

        public static org.apache.kafka.common.metrics.Sensor lateRecordDropSensor​(InternalProcessorContext context)
      • recordLatenessSensor

        public static org.apache.kafka.common.metrics.Sensor recordLatenessSensor​(InternalProcessorContext context)