Package org.apache.kafka.streams.processor.internals.metrics

Class ThreadMetrics

java.lang.Object

org.apache.kafka.streams.processor.internals.metrics.ThreadMetrics

public class ThreadMetrics
extends Object

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.metrics.Sensor	closeTaskSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	commitOverTasksSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	commitRatioSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	commitSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	createTaskSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	pollRatioSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	pollRecordsSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	pollSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	processLatencySensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	processRateSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	processRatioSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	processRecordsSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	punctuateRatioSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	punctuateSensor(String threadId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	skipRecordSensor(String threadId, StreamsMetricsImpl streamsMetrics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createTaskSensor

public static org.apache.kafka.common.metrics.Sensor createTaskSensor(String threadId,
                                                                      StreamsMetricsImpl streamsMetrics)

closeTaskSensor

public static org.apache.kafka.common.metrics.Sensor closeTaskSensor(String threadId,
                                                                     StreamsMetricsImpl streamsMetrics)

skipRecordSensor

public static org.apache.kafka.common.metrics.Sensor skipRecordSensor(String threadId,
                                                                      StreamsMetricsImpl streamsMetrics)

commitSensor

public static org.apache.kafka.common.metrics.Sensor commitSensor(String threadId,
                                                                  StreamsMetricsImpl streamsMetrics)

pollSensor

public static org.apache.kafka.common.metrics.Sensor pollSensor(String threadId,
                                                                StreamsMetricsImpl streamsMetrics)

processLatencySensor

public static org.apache.kafka.common.metrics.Sensor processLatencySensor(String threadId,
                                                                          StreamsMetricsImpl streamsMetrics)

pollRecordsSensor

public static org.apache.kafka.common.metrics.Sensor pollRecordsSensor(String threadId,
                                                                       StreamsMetricsImpl streamsMetrics)

processRecordsSensor

public static org.apache.kafka.common.metrics.Sensor processRecordsSensor(String threadId,
                                                                          StreamsMetricsImpl streamsMetrics)

processRateSensor

public static org.apache.kafka.common.metrics.Sensor processRateSensor(String threadId,
                                                                       StreamsMetricsImpl streamsMetrics)

punctuateSensor

public static org.apache.kafka.common.metrics.Sensor punctuateSensor(String threadId,
                                                                     StreamsMetricsImpl streamsMetrics)

commitOverTasksSensor

public static org.apache.kafka.common.metrics.Sensor commitOverTasksSensor(String threadId,
                                                                           StreamsMetricsImpl streamsMetrics)

processRatioSensor

public static org.apache.kafka.common.metrics.Sensor processRatioSensor(String threadId,
                                                                        StreamsMetricsImpl streamsMetrics)

punctuateRatioSensor

public static org.apache.kafka.common.metrics.Sensor punctuateRatioSensor(String threadId,
                                                                          StreamsMetricsImpl streamsMetrics)

pollRatioSensor

public static org.apache.kafka.common.metrics.Sensor pollRatioSensor(String threadId,
                                                                     StreamsMetricsImpl streamsMetrics)

commitRatioSensor

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