KafkaMetricsGroup

KafkaMetricsGroup is the abstraction of metrics groups that can register performance metrics, e.g. gauges, histograms, meters and timers.

package kafka.metrics

trait KafkaMetricsGroup {
  // No required properties (vals and methods) that have no implementation
}
Table 1. KafkaMetricsGroups (Direct Implementations)
KafkaMetricsGroup Description

AbstractFetcherManager

Acceptor

AdminManager

AppInfo

BrokerTopicMetrics

Topic metrics

ControllerChannelManager

ControllerEventManager

ControllerStats

DelayedDeleteRecordsMetrics

DelayedFetchMetrics

DelayedOperationPurgatory

DelayedProduceMetrics

DelegationTokenManager

FetcherLagMetrics

FetcherStats

FetchSessionCache

GroupMetadataManager

Consumer group metrics

KafkaController

KafkaRequestHandlerPool

KafkaServer

KafkaZkClient

Log

LogCleaner

LogCleanerManager

LogFlushStats

LogManager

Partition

Processor

ReplicaManager

RequestChannel

RequestMetrics

SocketServer

Throttler

TransactionMarkerChannelManager

ZooKeeperClient

newGauge Method

newGauge[T](
  name: String,
  metric: Gauge[T],
  tags: scala.collection.Map[String, String] = Map.empty): Gauge[T]

newGauge…​FIXME

Note
newGauge is used when…​FIXME

newMeter Method

newMeter(
  name: String,
  eventType: String,
  timeUnit: TimeUnit,
  tags: scala.collection.Map[String, String] = Map.empty): Meter

newMeter…​FIXME

Note
newMeter is used when…​FIXME

newHistogram Method

newHistogram(
  name: String,
  biased: Boolean = true,
  tags: scala.collection.Map[String, String] = Map.empty): Histogram

newHistogram…​FIXME

Note
newHistogram is used when…​FIXME

newTimer Method

newTimer(
  name: String,
  durationUnit: TimeUnit,
  rateUnit: TimeUnit,
  tags: scala.collection.Map[String, String] = Map.empty): Timer

newTimer…​FIXME

Note
newTimer is used when…​FIXME

metricName Method

metricName(name: String, tags: scala.collection.Map[String, String]): MetricName

metricName…​FIXME

Note
metricName is used when…​FIXME

results matching ""

    No results matching ""