StreamsMetricsImpl¶

StreamsMetricsImpl is a concrete StreamsMetrics.

Creating Instance¶

StreamsMetricsImpl takes the following to be created:

• Metrics (Apache Kafka)
• Client ID
• Built-in metrics version
• Time

StreamsMetricsImpl is created when:

• KafkaStreams is created
• TopologyTestDriver is requested to setupMetrics

RocksDBMetricsRecordingTrigger¶

StreamsMetricsImpl creates a RocksDBMetricsRecordingTrigger when created.

The RocksDBMetricsRecordingTrigger is used when:

• KafkaStreams is requested to start
• RocksDBMetricsRecorder is requested to addValueProviders and removeValueProviders

taskLevelSensor¶

Sensor taskLevelSensor(
  String threadId,
  String taskId,
  String sensorName,
  RecordingLevel recordingLevel,
  Sensor... parents)

taskLevelSensor creates a taskSensorPrefix (with the given threadId and taskId identifiers) and getSensors.

taskLevelSensor is used when:

• FIXME

getSensors¶

Sensor getSensors(
  Map<String, Deque<String>> sensors,
  String sensorName,
  String key,
  RecordingLevel recordingLevel,
  Sensor... parents)

getSensors...FIXME

getSensors is used when:

• StreamsMetricsImpl is requested to threadLevelSensor, taskLevelSensor, nodeLevelSensor, cacheLevelSensor, storeLevelSensor

threadLevelSensors¶

StreamsMetricsImpl defines threadLevelSensors registry of sensors (names) per thread (id) for threadLevelSensor.

Sensors are removed in removeAllThreadLevelSensors.