MetricCollector¶

MetricCollector is an abstraction of metrics collectors.

Contract¶

aggregateStat¶

double aggregateStat(
  String name,
  boolean isError)

Used when:

• MetricCollectors is requested to currentConsumptionRateByQuery and aggregateStat

stats¶

Collection<TopicSensors.Stat> stats(
  String topic,
  boolean isError)

Used when:

• MetricCollectors is requested to getStatsFor

Implementations¶

• ConsumerCollector
• ProducerCollector
• StreamsErrorCollector

errorRate¶

double errorRate()

errorRate is 0.0 by default.

errorRate is used when:

• MetricCollectors is requested to currentErrorRate

getGroupId¶

String getGroupId()

getGroupId is null (undefined) by default.

getGroupId is used when:

• MetricCollectors is requested to currentConsumptionRateByQuery