---
id: opentelemetry-instrumentation-aiokafka
version: "0.65b0"
license: Apache-2.0
license_treatment: permissive
maintenance: active
---

# opentelemetry-instrumentation-aiokafka — OpenTelemetry aiokafka instrumentation

License: permissive · Maintenance: active · Downloads: 5.4M/mo

## What it is and what it does

This package integrates aiokafka—the async Python Kafka client—with OpenTelemetry, the industry standard for distributed tracing. When installed and initialized, it automatically wraps Kafka producer and consumer calls to emit spans that track message flow, latency, and errors across your system. It depends on opentelemetry-api, opentelemetry-instrumentation, opentelemetry-semantic-conventions, and typing-extensions.

The instrumentation is designed for developers building async microservices that use Kafka for messaging and need end-to-end visibility into those operations. It integrates with any OpenTelemetry exporter (Jaeger, Datadog, etc.) to send traces to your observability backend. Since it's a thin wrapper around aiokafka, it adds minimal overhead and requires no changes to existing Kafka client code—just initialize the instrumentor once at startup.

Use it for:

- Trace Kafka message flow through a microservices architecture to identify latency bottlenecks.
- Monitor async producer and consumer error rates and correlate them with application traces.
- Debug message ordering or delivery issues by inspecting span metadata and timing.
- Correlate Kafka operations with upstream HTTP requests or database queries in a distributed system.
- Audit and visualize Kafka topic access patterns in a compliance or performance review.

## Worth the install?

AI-flagged interpretation of the facts above — verify before relying.

Adds distributed tracing instrumentation to aiokafka, automatically capturing Kafka producer and consumer operations as OpenTelemetry spans for observability.

Yes, if you are already using OpenTelemetry and aiokafka in a production system. The package is actively maintained, has no known vulnerabilities, and low install friction. Beta status is acceptable for observability instrumentation. Not necessary if you don't use aiokafka or don't have an OpenTelemetry exporter configured.

## Install

pip install opentelemetry-instrumentation-aiokafka
uv add opentelemetry-instrumentation-aiokafka
poetry add opentelemetry-instrumentation-aiokafka

## Installing opentelemetry-instrumentation-aiokafka

Before you install: Low friction install with a small, stable dependency tree. Actively maintained as of 2026-08-14 with recent releases; beta status reflects ongoing refinement rather than instability.

License in practice: Apache-2.0 permissive license allows use in commercial and proprietary projects with minimal restrictions.

Quickstart:

pip install opentelemetry-instrumentation-aiokafka

from opentelemetry.instrumentation.aiokafka import AiokafkaInstrumentor

AiokafkaInstrumentor().instrument()

Requires Python 3.10 or later; aiokafka must be installed separately to instrument.

Verify before relying:

- Whether instrumentation works with all aiokafka versions or has specific compatibility constraints.
- Performance overhead of tracing on high-throughput Kafka workloads.
- Whether span attributes capture message keys, values, or only metadata.

## Package facts

- License: Apache-2.0 (permissive)
- Python support: supports_current
- Install friction: low
- Maintenance: active
- Downloads: 5.4M/month (top 5,000 on PyPI)
- Known vulnerabilities: none known

## Tags

kafka tracing instrumentation, opentelemetry kafka monitoring, aiokafka distributed tracing, kafka span collection, async kafka observability, kafka producer consumer tracing, observability, kafka, async

[View on SkillFed](https://skillfed.io/packages/opentelemetry-instrumentation-aiokafka) · [View on PyPI](https://pypi.org/project/opentelemetry-instrumentation-aiokafka/)