kafka
Internal Telemetry
The following telemetry is emitted by this component.
otelcol_kafka_broker_closed
The total number of connections closed. [development]
Only produced when franz-go is enabled.
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
otelcol_kafka_broker_connects
The total number of connections opened. [development]
Only produced when franz-go is enabled.
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
| outcome |
The operation outcome. |
Str: success, failure |
otelcol_kafka_broker_throttling_duration
The throttling duration in ms imposed by the broker when receiving messages. [deprecated]
Only produced when franz-go is enabled. Deprecated in favor of kafka_broker_throttling_latency.
| Unit |
Metric Type |
Value Type |
Stability |
| ms |
Histogram |
Int |
deprecated |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
otelcol_kafka_broker_throttling_latency
The throttling latency in seconds imposed by the broker when receiving records. [development]
Only produced when franz-go is enabled.
| Unit |
Metric Type |
Value Type |
Stability |
| s |
Histogram |
Double |
development |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
otelcol_kafka_receiver_bytes
The size in bytes of received records seen by the broker. [development]
Only produced when franz-go is enabled.
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| By |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
| outcome |
The operation outcome. |
Str: success, failure |
otelcol_kafka_receiver_bytes_uncompressed
The uncompressed size in bytes of received records seen by the client. [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| By |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
| outcome |
The operation outcome. |
Str: success, failure |
otelcol_kafka_receiver_current_offset
Current message offset [development]
| Unit |
Metric Type |
Value Type |
Stability |
| 1 |
Gauge |
Int |
development |
Attributes
| Name |
Description |
Values |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
otelcol_kafka_receiver_latency
The time it took in ms to receive a batch of messages. [deprecated]
Only produced when franz-go is enabled. Deprecated in favor of kafka_receiver_read_latency.
| Unit |
Metric Type |
Value Type |
Stability |
| ms |
Histogram |
Int |
deprecated |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
| outcome |
The operation outcome. |
Str: success, failure |
otelcol_kafka_receiver_messages
The number of received messages. [deprecated]
Deprecated in favor of kafka_receiver_records.
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
deprecated |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
| outcome |
The operation outcome. |
Str: success, failure |
otelcol_kafka_receiver_offset_lag
Current offset lag [development]
| Unit |
Metric Type |
Value Type |
Stability |
| 1 |
Gauge |
Int |
development |
Attributes
| Name |
Description |
Values |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
otelcol_kafka_receiver_partition_close
Number of finished partitions [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
otelcol_kafka_receiver_partition_start
Number of started partitions [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
otelcol_kafka_receiver_read_latency
The time it took in seconds to receive a batch of records. [development]
Only produced when franz-go is enabled.
| Unit |
Metric Type |
Value Type |
Stability |
| s |
Histogram |
Double |
development |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
| outcome |
The operation outcome. |
Str: success, failure |
otelcol_kafka_receiver_records
The number of received records. [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| node_id |
The Kafka node ID. |
Any Int |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
| outcome |
The operation outcome. |
Str: success, failure |
otelcol_kafka_receiver_records_delay
The time in seconds between producing and receiving a batch of records. [development]
Optional, only reported when enabled via config.
Note that this metric may slow down high-volume consuming.
Only produced when franz-go is enabled.
This metric is reported with an assumption that the exporter and the receiver clocks are synchronized.
| Unit |
Metric Type |
Value Type |
Stability |
| s |
Histogram |
Double |
development |
Attributes
| Name |
Description |
Values |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
otelcol_kafka_receiver_unmarshal_failed_log_records
Number of log records failed to be unmarshaled [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
otelcol_kafka_receiver_unmarshal_failed_metric_points
Number of metric points failed to be unmarshaled [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
otelcol_kafka_receiver_unmarshal_failed_profiles
Number of profiles failed to be unmarshaled [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |
otelcol_kafka_receiver_unmarshal_failed_spans
Number of spans failed to be unmarshaled [development]
| Unit |
Metric Type |
Value Type |
Monotonic |
Stability |
| 1 |
Sum |
Int |
true |
development |
Attributes
| Name |
Description |
Values |
| topic |
The Kafka topic. |
Any Str |
| partition |
The Kafka topic partition. |
Any Int |