Class ThreadMetrics


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

      • createTaskSensor

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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