opentelemetry-instrumentation-aiokafka

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 on this page — 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

opentelemetry-instrumentation-aiokafka on PyPI

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

Evidence: opentelemetry_instrumentation_aiokafka-0.65b0-py3-none-any.whl

Tags

More Monitoring packages