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¶

StreamsMetricsImpl