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/kafkaexporter.md.

Kafka Exporter

OpenTelemetry Collector exporter · contrib distribution

  • Component ID: contrib-kafkaexporter
  • Name: kafkaexporter
  • Type: exporter
  • Distribution: contrib
  • Repository: opentelemetry-collector-contrib

Stability

LevelSignals
betalogs, metrics, traces
developmentprofiles

Internal telemetry

MetricTypeValue typeUnitStabilityEnabledAttributesDescription
kafka_broker_closedsum (monotonic)int1developmentyesnode_id (int), server.address (string)The total number of connections closed. Only produced when franz-go is enabled.
kafka_broker_connectssum (monotonic)int1developmentyesnode_id (int), outcome (string), server.address (string)The total number of connections opened. Only produced when franz-go is enabled.
kafka_broker_throttling_durationhistogramintmsdeprecatedyesnode_id (int), server.address (string)The throttling duration in ms imposed by the broker when exporting messages. Only produced when franz-go is enabled. Deprecated in favor of kafka_broker_throttling_latency.
kafka_broker_throttling_latencyhistogramdoublesdevelopmentyesnode_id (int), server.address (string)The throttling latency in seconds imposed by the broker when exporting records. Only produced when franz-go is enabled.
kafka_exporter_bytessum (monotonic)intBydevelopmentyesnode_id (int), outcome (string), partition (int), server.address (string), topic (string)The size in bytes of exported records seen by the broker. Only produced when franz-go is enabled.
kafka_exporter_bytes_uncompressedsum (monotonic)intBydevelopmentyesnode_id (int), outcome (string), partition (int), server.address (string), topic (string)The uncompressed size in bytes of exported messages seen by the client.
kafka_exporter_latencyhistogramintmsdeprecatedyesnode_id (int), outcome (string), partition (int), server.address (string), topic (string)The time it took in ms to export a batch of messages. Deprecated in favor of kafka_exporter_write_latency.
kafka_exporter_messagessum (monotonic)int1deprecatedyesnode_id (int), outcome (string), partition (int), server.address (string), topic (string)The number of exported messages. Deprecated in favor of kafka_exporter_records.
kafka_exporter_recordssum (monotonic)int1developmentyesnode_id (int), outcome (string), partition (int), server.address (string), topic (string)The number of exported records.
kafka_exporter_write_latencyhistogramdoublesdevelopmentyesnode_id (int), outcome (string), partition (int), server.address (string), topic (string)The time it took in seconds to export a batch of records.

Attributes

AttributeTypeDescription
node_idintThe Kafka node ID.
outcomestringThe operation outcome.
partitionintThe Kafka topic partition.
server.addressstringThe Kafka node address.
topicstringThe Kafka topic.

Data

  • JSON (latest): /data/collector/components/contrib-kafkaexporter/latest.json
  • JSON (pinned): /data/collector/components/contrib-kafkaexporter/contrib-kafkaexporter-43ae123621f4.json
  • Explore: /collector/components/contrib/kafkaexporter