org.apache.kafka.streams

Interface StreamsMetrics

public interface StreamsMetrics

The Kafka Streams metrics interface for adding metric sensors and collecting metric values.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.kafka.common.metrics.Sensor	addLatencySensor(String scopeName, String entityName, String operationName, String... tags)
void	recordLatency(org.apache.kafka.common.metrics.Sensor sensor, long startNs, long endNs)

Method Detail

addLatencySensor

org.apache.kafka.common.metrics.Sensor addLatencySensor(String scopeName,
                                                      String entityName,
                                                      String operationName,
                                                      String... tags)

recordLatency

void recordLatency(org.apache.kafka.common.metrics.Sensor sensor,
                 long startNs,
                 long endNs)