Class ProcessorNodeMetrics


  • public class ProcessorNodeMetrics
    extends java.lang.Object
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static org.apache.kafka.common.metrics.Sensor createSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor destroySensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor forwardSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor lateRecordDropSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor processAtSourceSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor processorAtSourceSensorOrForwardSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor processSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor punctuateSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor skippedIdempotentUpdatesSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor suppressionEmitSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String processorNodeId, StreamsMetricsImpl streamsMetrics)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • suppressionEmitSensor

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

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

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

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

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

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

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

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

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

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