This documentation has an index for AI agents at /llms.txt. A Markdown version of this page is available at https://explorer.opentelemetry.io/collector/components/contrib/kafkametricsreceiver.md.

Kafka Metrics Receiver

OpenTelemetry Collector receiver · contrib distribution

The Kafka Metrics Receiver collects kafka metrics (brokers, topics, partitions, consumer groups) from a kafka server, and converts them into otlp.

Component ID: contrib-kafkametricsreceiver
Name: kafkametricsreceiver
Type: receiver
Distribution: contrib
Repository: opentelemetry-collector-contrib

Stability

Level	Signals
beta	metrics

Metrics

Metric	Type	Value type	Unit	Stability	Enabled	Attributes	Description
`kafka.broker.log_retention_period`	gauge	int	s	development	no	`broker` (string)	log retention time (s) of a broker.
`kafka.brokers`	sum	int	{brokers}	development	yes		Number of brokers in the cluster.
`kafka.consumer_group.lag`	gauge	int	1	development	yes	`group` (string), `partition` (int), `topic` (string)	Current approximate lag of consumer group at partition of topic
`kafka.consumer_group.lag_sum`	gauge	int	1	development	yes	`group` (string), `topic` (string)	Current approximate sum of consumer group lag across all partitions of topic
`kafka.consumer_group.members`	sum	int	{members}	development	yes	`group` (string)	Count of members in the consumer group
`kafka.consumer_group.offset`	gauge	int	1	development	yes	`group` (string), `partition` (int), `topic` (string)	Current offset of the consumer group at partition of topic
`kafka.consumer_group.offset_sum`	gauge	int	1	development	yes	`group` (string), `topic` (string)	Sum of consumer group offset across partitions of topic
`kafka.partition.current_offset`	gauge	int	1	development	yes	`partition` (int), `topic` (string)	Current offset of partition of topic.
`kafka.partition.oldest_offset`	gauge	int	1	development	yes	`partition` (int), `topic` (string)	Oldest offset of partition of topic
`kafka.partition.replicas`	sum	int	{replicas}	development	yes	`partition` (int), `topic` (string)	Number of replicas for partition of topic
`kafka.partition.replicas_in_sync`	sum	int	{replicas}	development	yes	`partition` (int), `topic` (string)	Number of synchronized replicas of partition
`kafka.topic.log_retention_period`	gauge	int	s	development	no	`topic` (string)	log retention period of a topic (s).
`kafka.topic.log_retention_size`	gauge	int	By	development	no	`topic` (string)	log retention size of a topic in Bytes, The value (-1) indicates infinite size.
`kafka.topic.min_insync_replicas`	gauge	int	{replicas}	development	no	`topic` (string)	minimum in-sync replicas of a topic.
`kafka.topic.partitions`	sum	int	{partitions}	development	yes	`topic` (string)	Number of partitions in topic.
`kafka.topic.replication_factor`	gauge	int	1	development	no	`topic` (string)	replication factor of a topic.

Attributes

Attribute	Type	Description
`broker`	string	The ID of the kafka broker
`group`	string	The ID (string) of a consumer group
`partition`	int	The number (integer) of the partition
`topic`	string	The ID (integer) of a topic

Data

JSON (latest): /data/collector/components/contrib-kafkametricsreceiver/latest.json
JSON (pinned): /data/collector/components/contrib-kafkametricsreceiver/contrib-kafkametricsreceiver-5db2039480e3.json
Explore: /collector/components/contrib/kafkametricsreceiver