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

Class ProcessorNodeMetrics

java.lang.Object

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

public class ProcessorNodeMetrics
extends Object

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.metrics.Sensor	createSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	destroySensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	forwardSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	lateRecordDropSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	processAtSourceSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	processorAtSourceSensorOrForwardSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	processSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	punctuateSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	skippedIdempotentUpdatesSensor(String threadId, String taskId, String processorNodeId, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	suppressionEmitSensor(String threadId, String taskId, 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(String threadId,
                                                                           String taskId,
                                                                           String processorNodeId,
                                                                           StreamsMetricsImpl streamsMetrics)

skippedIdempotentUpdatesSensor

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

processSensor

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

processAtSourceSensor

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

punctuateSensor

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

createSensor

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

destroySensor

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

forwardSensor

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

lateRecordDropSensor

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

processorAtSourceSensorOrForwardSensor

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