confluent-kafka
Confluent's Python client for Apache Kafka
Decision gist · record as of 2026-08-14
Yes. The package is production-stable, actively maintained, widely adopted (top 1000 on PyPI), has no known vulnerabilities, and offers genuine performance and feature advantages over pure-Python alternatives for production Kafka workloads. Install friction is moderate but manageable via pre-built wheels. Choose it if you need reliable, high-performance Kafka integration; avoid it only if you cannot accept the compiled C dependency or are building a minimal prototype.AI-flagged interpretation of the facts on this page — verify before relying
Before you install
- Requires librdkafka C library; wheels include pre-built bindings for common platforms but compilation may be needed on unsupported architectures.
- Medium install friction due to compiled C bindings (librdkafka), but pre-built wheels are available for Python 3.10–3.13 across macOS, Linux, and Windows.
- Actively maintained with a release 45 days ago.
License · maintenance · safety
permissive license (permissive) — Licensed under Apache License (permissive), allowing use in commercial and open-source projects with minimal restrictions.
last release 2026-06-30 (45 days) · last repo commit 2026-08-13 · 501 stars
0 known vulnerabilities (OSV.dev, 2026-08-14) · 63,434,267 downloads/mo, #493 on PyPI
Alternatives
Verify before relying
pip install confluent-kafka
from confluent_kafka import Producer
p = Producer({'bootstrap.servers': 'mybroker'})
p.produce('mytopic', value=b'hello')
p.flush()- Whether asyncio producer is production-ready or still considered experimental despite marketing language.
- Performance comparison specifics: description claims 'significantly outperforming' pure Python but provides no benchmarks or throughput figures.
- Actual throughput and latency improvements over pure-Python implementations in real-world scenarios.
What it is and what it does
confluent-kafka is a Python wrapper around librdkafka, Confluent's high-performance C library for Kafka. It provides synchronous and asynchronous producers and consumers, an admin client, and built-in support for Avro, Protobuf, and JSON Schema serialization via Schema Registry integration. Unlike pure-Python Kafka clients, it is optimized for throughput and latency in production environments and supports transactions and exactly-once semantics.
The package targets developers building event-driven applications that need reliable, low-latency message publishing and consumption. It works with Apache Kafka brokers >= v0.8, Confluent Cloud, and Confluent Platform. The synchronous API is suitable for batch jobs and high-throughput pipelines; the asyncio producer integrates with modern async frameworks without blocking the event loop.
Use it for
- Building event streaming pipelines that require high throughput and low latency with transactional guarantees.
- Integrating Kafka into asyncio-based web services using the async producer.
- Consuming and producing messages with automatic schema evolution via Confluent Schema Registry.
- Implementing exactly-once message processing semantics in data processing applications.
- Monitoring and administering Kafka clusters programmatically via the AdminClient API.
Worth the install?
AI-flagged interpretation of the facts on this page. Verify before relying on it.
Yes.
The package is production-stable, actively maintained, widely adopted (top 1000 on PyPI), has no known vulnerabilities, and offers genuine performance and feature advantages over pure-Python alternatives for production Kafka workloads. Install friction is moderate but manageable via pre-built wheels. Choose it if you need reliable, high-performance Kafka integration; avoid it only if you cannot accept the compiled C dependency or are building a minimal prototype.
Install
confluent-kafka on PyPI
Before you install
Medium install friction due to compiled C bindings (librdkafka), but pre-built wheels are available for Python 3.10–3.13 across macOS, Linux, and Windows. Actively maintained with a release 45 days ago.
Requires librdkafka C library; wheels include pre-built bindings for common platforms but compilation may be needed on unsupported architectures.
License in practice
Licensed under Apache License (permissive), allowing use in commercial and open-source projects with minimal restrictions.
Quickstart
pip install confluent-kafka
from confluent_kafka import Producer
p = Producer({'bootstrap.servers': 'mybroker'})
p.produce('mytopic', value=b'hello')
p.flush()Verify before relying
- Whether asyncio producer is production-ready or still considered experimental despite marketing language.
- Performance comparison specifics: description claims 'significantly outperforming' pure Python but provides no benchmarks or throughput figures.
- Actual throughput and latency improvements over pure-Python implementations in real-world scenarios.
Package facts
| License | permissive license permissive |
| Python support | Supports the current Python release >=3.8 |
| Install friction | Medium. Platform-specific wheel |
| Runtime dependencies | 1 packagetyping-extensions |
| Maintenance | Actively maintained 45 days since the last release |
| Last repo commit | |
| First released | |
| Downloads | 63,434,267 / month, #493 on PyPI 30-day window, as of 2026-08-14 |
| Known vulnerabilities | None known OSV.dev, checked 2026-08-14 |
| Classifiers | Development Status :: 5 - Production/StableIntended Audience :: DevelopersLicense :: OSI Approved :: Apache Software LicenseProgramming Language :: PythonProgramming Language :: Python :: 3Topic :: Software Development :: Libraries :: Python Modules |
Evidence: confluent_kafka-2.15.0-cp310-cp310-macosx_10_9_x86_64.whl; confluent_kafka-2.15.0-cp310-cp310-macosx_11_0_arm64.whl; confluent_kafka-2.15.0-cp310-cp310-manylinux_2_28_aarch64.whl; confluent_kafka-2.15.0-cp310-cp310-manylinux_2_28_x86_64.whl; confluent_kafka-2.15.0-cp310-cp310-win_amd64.whl; confluent_kafka-2.15.0-cp311-cp311-macosx_10_9_x86_64.whl; confluent_kafka-2.15.0-cp311-cp311-macosx_11_0_arm64.whl; confluent_kafka-2.15.0-cp311-cp311-manylinux_2_28_aarch64.whl; confluent_kafka-2.15.0-cp311-cp311-manylinux_2_28_x86_64.whl; confluent_kafka-2.15.0-cp311-cp311-win_amd64.whl; confluent_kafka-2.15.0-cp312-cp312-macosx_10_9_x86_64.whl; confluent_kafka-2.15.0-cp312-cp312-macosx_11_0_arm64.whl; confluent_kafka-2.15.0-cp312-cp312-manylinux_2_28_aarch64.whl; confluent_kafka-2.15.0-cp312-cp312-manylinux_2_28_x86_64.whl; confluent_kafka-2.15.0-cp312-cp312-win_amd64.whl; confluent_kafka-2.15.0-cp313-cp313-macosx_13_0_arm64.whl; confluent_kafka-2.15.0-cp313-cp313-macosx_13_0_x86_64.whl; confluent_kafka-2.15.0-cp313-cp313-manylinux_2_28_aarch64.whl; confluent_kafka-2.15.0-cp313-cp313-manylinux_2_28_x86_64.whl; confluent_kafka-2.15.0-cp313-cp313-win_amd64.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 › “high performance kafka client”
- confluent-kafkaProvides a high-performance Python client for Apache Kafka that wraps…
- kafka-pythonPure-Python Apache Kafka client library providing high-level…
- kafka-python-ngA Python client library for Apache Kafka that provides high-level…
Give your agent the search over MCP, or paste the wish link into any chat.
More Python Modules packages
Converts domain names between Unicode and ASCII-compatible encoding (Punycode) according to IDNA 2008 and Unicode Technical Standard 46, with security validation and broader script coverage than the standard library.
Install it if you work with internationalized domain names, need to validate domains, or use HTTP clients that depend on it transitively.
Setuptools is a Python build backend and package management tool that handles building, distributing, and installing Python packages, including support for C/C++ extension modules.
PyYAML parses and emits YAML 1.1 data format, enabling serialization and deserialization of configuration files and Python objects to and from human-readable YAML text.
Pydantic validates Python data structures against type hints, coercing and checking input at runtime to ensure it matches a declared schema.
Provides reusable metadata objects for use with PEP-593 `typing.Annotated` to express common constraints like bounds, collection sizes, and predicates on types.
Install it if you use or build libraries that need to express type constraints in a standardized, inspectable way—or if you want to annotate your own types with…
Provides runtime tools to inspect and introspect Python type annotations, enabling programmatic examination of type hints at execution time.
See also confluent_avro · kafka · kafka-connect-py · python-schema-registry-client · kafka-python · kafka-schema-registry · pulumi-confluentcloud · kafka-python-ng · aiokafka · orion-py-client