# Apache Kafka Client

<!-- llms-txt-link: /llms.txt -->

> OpenTelemetry Java agent instrumentation

This standalone instrumentation enables messaging spans for Kafka producers and consumers, and collects internal Kafka client metrics.

- **Name**: `kafka-clients-2.6`
- **Scope**: `io.opentelemetry.kafka-clients-2.6`
- **Library**: https://kafka.apache.org/

## Telemetry

- **Span attributes**: `kafka.record.queue_time_ms`, `messaging.batch.message_count`, `messaging.client_id`, `messaging.destination.name`, `messaging.destination.partition.id`, `messaging.kafka.consumer.group`, `messaging.kafka.message.offset`, `messaging.message.body.size`, `messaging.operation`, `messaging.system`, `messaging.kafka.bootstrap.servers`, `messaging.kafka.message.key`

## Data

- **JSON**: [/data/javaagent/instrumentations/kafka-clients-2.6/kafka-clients-2.6-551e3820d94f.json](/data/javaagent/instrumentations/kafka-clients-2.6/kafka-clients-2.6-551e3820d94f.json)
- **Explore**: [/java-agent/instrumentation/kafka-clients-2.6](/java-agent/instrumentation/kafka-clients-2.6)