Class TaskMetrics


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

      • processLatencySensor

        public static org.apache.kafka.common.metrics.Sensor processLatencySensor​(java.lang.String threadId,
                                                                                  java.lang.String taskId,
                                                                                  StreamsMetricsImpl streamsMetrics)
      • activeProcessRatioSensor

        public static org.apache.kafka.common.metrics.Sensor activeProcessRatioSensor​(java.lang.String threadId,
                                                                                      java.lang.String taskId,
                                                                                      StreamsMetricsImpl streamsMetrics)
      • activeBufferedRecordsSensor

        public static org.apache.kafka.common.metrics.Sensor activeBufferedRecordsSensor​(java.lang.String threadId,
                                                                                         java.lang.String taskId,
                                                                                         StreamsMetricsImpl streamsMetrics)
      • e2ELatencySensor

        public static org.apache.kafka.common.metrics.Sensor e2ELatencySensor​(java.lang.String threadId,
                                                                              java.lang.String taskId,
                                                                              java.lang.String processorNodeId,
                                                                              org.apache.kafka.common.metrics.Sensor.RecordingLevel recordingLevel,
                                                                              StreamsMetricsImpl streamsMetrics)
      • punctuateSensor

        public static org.apache.kafka.common.metrics.Sensor punctuateSensor​(java.lang.String threadId,
                                                                             java.lang.String taskId,
                                                                             StreamsMetricsImpl streamsMetrics)
      • commitSensor

        public static org.apache.kafka.common.metrics.Sensor commitSensor​(java.lang.String threadId,
                                                                          java.lang.String taskId,
                                                                          StreamsMetricsImpl streamsMetrics,
                                                                          org.apache.kafka.common.metrics.Sensor... parentSensor)
      • enforcedProcessingSensor

        public static org.apache.kafka.common.metrics.Sensor enforcedProcessingSensor​(java.lang.String threadId,
                                                                                      java.lang.String taskId,
                                                                                      StreamsMetricsImpl streamsMetrics,
                                                                                      org.apache.kafka.common.metrics.Sensor... parentSensors)
      • recordLatenessSensor

        public static org.apache.kafka.common.metrics.Sensor recordLatenessSensor​(java.lang.String threadId,
                                                                                  java.lang.String taskId,
                                                                                  StreamsMetricsImpl streamsMetrics)
      • droppedRecordsSensor

        public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensor​(java.lang.String threadId,
                                                                                  java.lang.String taskId,
                                                                                  StreamsMetricsImpl streamsMetrics)
      • droppedRecordsSensorOrSkippedRecordsSensor

        public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensorOrSkippedRecordsSensor​(java.lang.String threadId,
                                                                                                        java.lang.String taskId,
                                                                                                        StreamsMetricsImpl streamsMetrics)
      • droppedRecordsSensorOrExpiredWindowRecordDropSensor

        public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensorOrExpiredWindowRecordDropSensor​(java.lang.String threadId,
                                                                                                                 java.lang.String taskId,
                                                                                                                 java.lang.String storeType,
                                                                                                                 java.lang.String storeName,
                                                                                                                 StreamsMetricsImpl streamsMetrics)
      • droppedRecordsSensorOrLateRecordDropSensor

        public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensorOrLateRecordDropSensor​(java.lang.String threadId,
                                                                                                        java.lang.String taskId,
                                                                                                        java.lang.String processorNodeId,
                                                                                                        StreamsMetricsImpl streamsMetrics)