opentelemetry-instrumentation-kafka-python
OpenTelemetry Kafka-Python instrumentation
Decision gist · record as of 2026-08-14
Yes, if you are already using OpenTelemetry in your Python stack and need visibility into Kafka producer/consumer operations. The low install friction, active maintenance, and permissive license make it a straightforward addition to observability pipelines. The beta status is not a blocker for production use in the OpenTelemetry ecosystem, but verify that the span attributes and export behavior meet your observability requirements before deploying.AI-flagged interpretation of the facts on this page — verify before relying
Before you install
- Requires Python 3.10 or later; kafka-python library must be installed separately for the instrumentation to function.
- Low friction install with three stable OpenTelemetry runtime dependencies.
- Active maintenance with recent release (29 days old), last commit 2026-08-14, and 1086 repository stars.
License · maintenance · safety
Apache-2.0 (permissive) — Apache-2.0 permissive license allows commercial and private use with minimal restrictions, typical for OpenTelemetry ecosystem packages.
last release 2026-07-16 (29 days) · last repo commit 2026-08-14 · 1,086 stars
0 known vulnerabilities (OSV.dev, 2026-08-14) · 5,923,662 downloads/mo, #2,012 on PyPI
Alternatives
Verify before relying
pip install opentelemetry-instrumentation-kafka-python
from opentelemetry.instrumentation.kafka import KafkaInstrumentor
KafkaInstrumentor().instrument()- Whether the instrumentation auto-detects existing kafka-python instances or requires explicit setup per producer/consumer.
- What span attributes and metrics are captured for Kafka operations (message size, partition, offset, etc.).
- Whether there are performance or latency implications for high-throughput Kafka workloads.
What it is and what it does
This package integrates OpenTelemetry tracing into kafka-python applications, automatically instrumenting Kafka producer and consumer operations to emit spans that can be exported to observability backends. It is part of the OpenTelemetry Python contrib ecosystem and works alongside the core opentelemetry-api, opentelemetry-instrumentation, and opentelemetry-semantic-conventions packages to provide standards-based distributed tracing for Kafka workloads.
The instrumentation is designed to work with existing kafka-python code with minimal changes—typically just initializing the KafkaInstrumentor. It captures Kafka message flow and operation details as spans, enabling developers to trace requests across services that produce or consume Kafka messages. The package is in beta (0.65b0) and actively maintained, supporting Python 3.10 through 3.14.
Use it for
- Trace Kafka message flow across microservices to identify latency bottlenecks in event-driven architectures.
- Monitor producer and consumer performance by exporting spans to a tracing backend like Jaeger or Zipkin.
- Correlate Kafka operations with application logs and metrics for end-to-end observability of message processing.
- Debug message loss or ordering issues by inspecting span context and metadata captured during Kafka operations.
- Measure Kafka instrumentation overhead in production by comparing latency before and after enabling tracing.
Worth the install?
AI-flagged interpretation of the facts on this page. Verify before relying on it.
Yes, if you are already using OpenTelemetry in your Python stack and need visibility into Kafka producer/consumer operations.
The low install friction, active maintenance, and permissive license make it a straightforward addition to observability pipelines. The beta status is not a blocker for production use in the OpenTelemetry ecosystem, but verify that the span attributes and export behavior meet your observability requirements before deploying.
Install
opentelemetry-instrumentation-kafka-python on PyPI
Before you install
Low friction install with three stable OpenTelemetry runtime dependencies. Active maintenance with recent release (29 days old), last commit 2026-08-14, and 1086 repository stars. Beta status (0.65b0) indicates the instrumentation is still maturing but actively developed.
Requires Python 3.10 or later; kafka-python library must be installed separately for the instrumentation to function.
License in practice
Apache-2.0 permissive license allows commercial and private use with minimal restrictions, typical for OpenTelemetry ecosystem packages.
Quickstart
pip install opentelemetry-instrumentation-kafka-python
from opentelemetry.instrumentation.kafka import KafkaInstrumentor
KafkaInstrumentor().instrument()Verify before relying
- Whether the instrumentation auto-detects existing kafka-python instances or requires explicit setup per producer/consumer.
- What span attributes and metrics are captured for Kafka operations (message size, partition, offset, etc.).
- Whether there are performance or latency implications for high-throughput Kafka workloads.
Package facts
| License | Apache-2.0 permissive |
| Python support | Supports the current Python release >=3.10 |
| Install friction | Low. Pure-Python wheel |
| Runtime dependencies | 3 packagesopentelemetry-apiopentelemetry-instrumentationopentelemetry-semantic-conventions |
| Maintenance | Actively maintained 29 days since the last release |
| Last repo commit | |
| First released | |
| Downloads | 5,923,662 / month, #2,012 on PyPI 30-day window, as of 2026-08-14 |
| Known vulnerabilities | None known OSV.dev, checked 2026-08-14 |
| Classifiers | Development Status :: 4 - BetaIntended Audience :: DevelopersLicense :: OSI Approved :: Apache Software LicenseProgramming Language :: PythonProgramming Language :: Python :: 3Programming Language :: Python :: 3.10Programming Language :: Python :: 3.11Programming Language :: Python :: 3.12Programming Language :: Python :: 3.13Programming Language :: Python :: 3.14 |
Evidence: opentelemetry_instrumentation_kafka_python-0.65b0-py3-none-any.whl
Tags
Let your AI agent find packages like this
Example. Real query, live index.
You found this page by searching. An agent finds it by wishing: SkillFed indexes 14,416 PyPI packages by what they can do, searchable in plain language.
wish › “kafka tracing instrumentation”
- opentelemetry-instrumentation-kafka-pythonAdds distributed tracing instrumentation to kafka-python…
- opentelemetry-instrumentation-aiokafkaAdds distributed tracing instrumentation to aiokafka, automatically…
- opentelemetry-instrumentation-confluent-kafkaAdds distributed tracing to confluent-kafka library calls, capturing…
Give your agent the search over MCP, or paste the wish link into any chat.
More Monitoring packages
Wraps any iterable to display a real-time progress bar in the terminal or Jupyter notebook, showing iteration count, elapsed time, and estimated time remaining.
Provides generated Python code for OpenTelemetry semantic conventions, enabling standardized attribute naming and constant definitions for instrumentation and telemetry collection.
Install it if you are using OpenTelemetry and want to follow semantic conventions correctly.
Provides the reference implementation of the OpenTelemetry API for collecting and exporting traces, metrics, and logs from Python applications.
Provides the abstract API and interfaces for OpenTelemetry instrumentation in Python, defining how to emit traces, metrics, and logs without tying code to a specific SDK implementation.
Exports OpenTelemetry observability data to an OpenTelemetry Collector using Protobuf-encoded messages over HTTP.
Install it if you are using OpenTelemetry in Python and need to send data to a Collector over HTTP.
Provides automatic instrumentation commands and programmatic APIs to inject distributed tracing into Python applications without code changes, detecting and instrumenting packages used by your program.
Install it if you need distributed tracing without code changes and have compatible instrumented packages in your environment.
See also opentelemetry-instrumentation-aiokafka · opentelemetry-instrumentation-confluent-kafka · opentelemetry-instrumentation-grpc · opentelemetry-instrumentation-pymemcache · opentelemetry-instrumentation-boto · opentelemetry-instrumentation-cassandra · opentelemetry-instrumentation-celery · opentelemetry-instrumentation-sklearn · opentelemetry-contrib-instrumentations · opentelemetry-instrumentation-exceptions