metrics

Documentation

Index

• Constants

Constants

const (
	KafkaConsumerStarted = "kafka.consumer.started"
	KafkaConsumerStopped = "kafka.consumer.stopped"

	KafkaPartitionStarted    = "kafka.partition.started"
	KafkaPartitionStopped    = "kafka.partition.stopped"
	KafkaPartitionMessagesIn = "kafka.partition.messages-in"

	KafkaDLQStarted       = "kafka.dlq.started"
	KafkaDLQStopped       = "kafka.dlq.stopped"
	KafkaDLQMessagesOut   = "kafka.dlq.messages-out"
	KafkaDLQErrors        = "kafka.dlq.errors"
	KafkaDLQMetadataError = "kafka.dlq.metadata-error"

	KafkaPartitionAckMgrDups     = "kafka.partition.ackmgr.duplicates"
	KafkaPartitionAckMgrSkipped  = "kafka.partition.ackmgr.skipped"
	KafkaPartitionAckMgrListFull = "kafka.partition.ackmgr.list-full-error"
	KafkaPartitionGetAckIDErrors = "kafka.partition.ackmgr.get-ackid-error"
	KafkaPartitionAck            = "kafka.partition.ack"
	KafkaPartitionAckErrors      = "kafka.partition.ackmgr.ack-error"
	KafkaPartitionNack           = "kafka.partition.nack"
	KafkaPartitionNackErrors     = "kafka.partition.ackmgr.nack-error"
	KafkaPartitionRebalance      = "kafka.partition.rebalance"
)

Counters

const (
	KafkaPartitionTimeLag            = "kafka.partition.time-lag"
	KafkaPartitionOffsetLag          = "kafka.partition.offset-lag"
	KafkaPartitionOffsetFreshnessLag = "kafka.partition.freshness-lag"
	KafkaPartitionReadOffset         = "kafka.partition.read-offset"
	KafkaPartitionCommitOffset       = "kafka.partition.commit-offset"
	KafkaPartitionOwnedCount         = "kafka.partition.owned.count"
	KafkaPartitionOwned              = "kafka.partition.owned"
)

Gauges