Skip to content

StreamsMetrics

StreamsMetrics is an abstraction of performance metric registries (of a KafkaStreams instance).

StreamsMetrics is available using ProcessorContext.

Contract

addLatencyRateTotalSensor

Sensor addLatencyRateTotalSensor(
  String scopeName,
  String entityName,
  String operationName,
  Sensor.RecordingLevel recordingLevel,
  String... tags)

addRateTotalSensor

Sensor addRateTotalSensor(
  String scopeName,
  String entityName,
  String operationName,
  Sensor.RecordingLevel recordingLevel,
  String... tags)

addSensor

Sensor addSensor(
  String name,
  Sensor.RecordingLevel recordingLevel)
Sensor addSensor(
  String name,
  Sensor.RecordingLevel recordingLevel,
  Sensor... parents)

metrics

Map<MetricName, ? extends Metric> metrics()

removeSensor

void removeSensor(
  Sensor sensor)

Implementations

Back to top