StreamsMetricsThreadImpl

StreamsMetricsThreadImpl is a concrete StreamsMetricsImpl.

StreamsMetricsThreadImpl is created for a StreamThread (when KafkaStreams is created).

Table 1. StreamsMetricsThreadImpl’s Sensors
Name Description

commitTimeSensor

pollTimeSensor

processTimeSensor

punctuateTimeSensor

taskCreatedSensor

tasksClosedSensor

skippedRecordsSensor

Creating StreamsMetricsThreadImpl Instance

StreamsMetricsThreadImpl takes the following when created:

  • Metrics

  • groupName

  • prefix

  • Tags (as Map<String, String>)

StreamsMetricsThreadImpl initializes the sensors.

createMeter Internal Method

Meter createMeter(Metrics metrics, SampledStat stat, String baseName, String descriptiveName)

createMeter…​FIXME

Note
 createMeter is used when…​FIXME

removeAllSensors Method

void removeAllSensors()

removeAllSensors…​FIXME

Note
 removeAllSensors is used when…​FIXME

results matching ""

    No results matching ""