Class TaskMetrics
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.metrics.TaskMetrics
-
public class TaskMetrics extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static org.apache.kafka.common.metrics.Sensor
activeBufferedRecordsSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
activeProcessRatioSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
commitSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Sensor... parentSensor)
static org.apache.kafka.common.metrics.Sensor
droppedRecordsSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
droppedRecordsSensorOrExpiredWindowRecordDropSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
droppedRecordsSensorOrLateRecordDropSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
droppedRecordsSensorOrSkippedRecordsSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
e2ELatencySensor(String threadId, String taskId, String processorNodeId, org.apache.kafka.common.metrics.Sensor.RecordingLevel recordingLevel, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
enforcedProcessingSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Sensor... parentSensors)
static org.apache.kafka.common.metrics.Sensor
processLatencySensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
punctuateSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor
recordLatenessSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
-
-
Method Detail
-
processLatencySensor
public static org.apache.kafka.common.metrics.Sensor processLatencySensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
activeProcessRatioSensor
public static org.apache.kafka.common.metrics.Sensor activeProcessRatioSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
activeBufferedRecordsSensor
public static org.apache.kafka.common.metrics.Sensor activeBufferedRecordsSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
e2ELatencySensor
public static org.apache.kafka.common.metrics.Sensor e2ELatencySensor(String threadId, String taskId, String processorNodeId, org.apache.kafka.common.metrics.Sensor.RecordingLevel recordingLevel, StreamsMetricsImpl streamsMetrics)
-
punctuateSensor
public static org.apache.kafka.common.metrics.Sensor punctuateSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
commitSensor
public static org.apache.kafka.common.metrics.Sensor commitSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Sensor... parentSensor)
-
enforcedProcessingSensor
public static org.apache.kafka.common.metrics.Sensor enforcedProcessingSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics, org.apache.kafka.common.metrics.Sensor... parentSensors)
-
recordLatenessSensor
public static org.apache.kafka.common.metrics.Sensor recordLatenessSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
droppedRecordsSensor
public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
droppedRecordsSensorOrSkippedRecordsSensor
public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensorOrSkippedRecordsSensor(String threadId, String taskId, StreamsMetricsImpl streamsMetrics)
-
droppedRecordsSensorOrExpiredWindowRecordDropSensor
public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensorOrExpiredWindowRecordDropSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
-
droppedRecordsSensorOrLateRecordDropSensor
public static org.apache.kafka.common.metrics.Sensor droppedRecordsSensorOrLateRecordDropSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
-
-