confluent-kafka has 57.3M monthly downloads and 492 GitHub stars. Version 2.15.0 supports Python 3.8+, first published in 2016.
It is actively maintained under a permissive license, last released in Jun 2026.
It is built on top of typing-extensions. It is used by 333 tracked packages, including apache-airflow-providers-apache-kafka, localstack-ext and rasa.
GitHub topics include confluent, kafka-client and librdkafka.
Package Insights
((week_daily_avg - month_daily_avg) / month_daily_avg) * 100Weekly Downloads
GitHub Stars
Downloads by OS
Python Versions
Top Countries
Dependencies
253 optional dependencies
- async-timeout[dev]
- async-timeout[all]
- async-timeout[tests]
- attrs[json]
- attrs[json-fast]
- attrs[protobuf]
- attrs[rules]
- attrs[schema-registry]
- attrs[schemaregistry]
- attrs[tests]
- attrs[dev]
- attrs[docs]
- attrs[all]
- attrs[examples]
- attrs[avro]
- authlib[avro]
- authlib[dev]
- authlib[docs]
- authlib[examples]
- authlib[json]
- authlib[json-fast]
- authlib[protobuf]
- authlib[rules]
- authlib[schema-registry]
- authlib[schemaregistry]
- authlib[tests]
- authlib[all]
- avro[avro]
- avro[all]
- avro[dev]
- avro[docs]
- avro[examples]
- avro[tests]
- azure-identity[dev]
- azure-identity[docs]
- azure-identity[examples]
- azure-identity[rules]
- azure-identity[tests]
- azure-identity[all]
- azure-keyvault-keys[dev]
- azure-keyvault-keys[docs]
- azure-keyvault-keys[examples]
- azure-keyvault-keys[rules]
- azure-keyvault-keys[tests]
- azure-keyvault-keys[all]
- black[dev]
- black[tests]
- black[all]
- boto3[dev]
- boto3[docs]
- boto3[examples]
- boto3[oauthbearer-aws]
- boto3[rules]
- boto3[tests]
- boto3[all]
- cachetools[json-fast]
- cachetools[all]
- cachetools[avro]
- cachetools[dev]
- cachetools[docs]
- cachetools[examples]
- cachetools[json]
- cachetools[protobuf]
- cachetools[rules]
- cachetools[schema-registry]
- cachetools[schemaregistry]
- cachetools[tests]
- cel-python[examples]
- cel-python[rules]
- cel-python[tests]
- cel-python[dev]
- cel-python[all]
- cel-python[docs]
- certifi[avro]
- certifi[dev]
- certifi[docs]
- certifi[json]
- certifi[json-fast]
- certifi[protobuf]
- certifi[rules]
- certifi[schema-registry]
- certifi[schemaregistry]
- certifi[tests]
- certifi[all]
- confluent-kafka[dev]
- confluent-kafka[examples]
- confluent-kafka[all]
- fastapi[all]
- fastapi[examples]
- fastapi[dev]
- fastavro[tests]
- fastavro[all]
- fastavro[avro]
- fastavro[dev]
- fastavro[docs]
- fastavro[examples]
- flake8[dev]
- flake8[tests]
- flake8[all]
- google-api-core[dev]
- google-api-core[docs]
- google-api-core[examples]
- google-api-core[rules]
- google-api-core[tests]
- google-api-core[all]
- google-auth[dev]
- google-auth[docs]
- google-auth[examples]
- google-auth[rules]
- google-auth[tests]
- google-auth[all]
- google-cloud-kms[dev]
- google-cloud-kms[docs]
- google-cloud-kms[examples]
- google-cloud-kms[rules]
- google-cloud-kms[tests]
- google-cloud-kms[all]
- google-re2[dev]
- google-re2[docs]
- google-re2[rules]
- google-re2[tests]
- google-re2[all]
- googleapis-common-protos[tests]
- googleapis-common-protos[all]
- googleapis-common-protos[dev]
- googleapis-common-protos[docs]
- googleapis-common-protos[examples]
- googleapis-common-protos[protobuf]
- hkdf[all]
- hkdf[rules]
- hkdf[tests]
- hkdf[dev]
- hkdf[docs]
- hkdf[examples]
- httpx[avro]
- httpx[dev]
- httpx[docs]
- httpx[examples]
- httpx[json]
- httpx[json-fast]
- httpx[protobuf]
- httpx[rules]
- httpx[schema-registry]
- httpx[schemaregistry]
- httpx[tests]
- httpx[all]
- hvac[all]
- hvac[docs]
- hvac[examples]
- hvac[rules]
- hvac[tests]
- hvac[dev]
- isort[tests]
- isort[dev]
- isort[all]
- jsonata-python[tests]
- jsonata-python[all]
- jsonata-python[dev]
- jsonata-python[docs]
- jsonata-python[examples]
- jsonata-python[rules]
- jsonschema[dev]
- jsonschema[docs]
- jsonschema[examples]
- jsonschema[json]
- jsonschema[json-fast]
- jsonschema[tests]
- jsonschema[all]
- mypy[dev]
- mypy[tests]
- mypy[all]
- opentelemetry-distro[soaktest]
- opentelemetry-distro[all]
- opentelemetry-exporter-otlp[soaktest]
- opentelemetry-exporter-otlp[all]
- orjson[json-fast]
- pandoc[dev]
- pandoc[docs]
- pandoc[all]
- pluggy[dev]
- pluggy[tests]
- pluggy[all]
- protobuf[all]
- protobuf[docs]
- protobuf[examples]
- protobuf[protobuf]
- protobuf[tests]
- protobuf[dev]
- psutil[soaktest]
- psutil[all]
- pydantic[dev]
- pydantic[all]
- pydantic[examples]
- pytest[dev]
- pytest[all]
- pytest[tests]
- pytest-asyncio[tests]
- pytest-asyncio[dev]
- pytest-asyncio[all]
- pytest-cov[all]
- pytest-cov[dev]
- pytest-cov[tests]
- pytest-timeout[all]
- pytest-timeout[tests]
- pytest-timeout[dev]
- pyyaml[tests]
- pyyaml[all]
- pyyaml[dev]
- pyyaml[docs]
- pyyaml[examples]
- pyyaml[rules]
- requests[avro]
- requests[docs]
- requests[all]
- requests[examples]
- requests[tests]
- requests[dev]
- requests-mock[dev]
- requests-mock[all]
- requests-mock[tests]
- respx[dev]
- respx[all]
- respx[tests]
- six[dev]
- six[all]
- six[examples]
- sphinx[dev]
- sphinx[all]
- sphinx[docs]
- sphinx-rtd-theme[all]
- sphinx-rtd-theme[dev]
- sphinx-rtd-theme[docs]
- tink[dev]
- tink[docs]
- tink[examples]
- tink[rules]
- tink[tests]
- tink[all]
- tomli[docs]
- tomli[all]
- tomli[dev]
- types-cachetools[dev]
- types-cachetools[tests]
- types-cachetools[all]
- types-requests[all]
- types-requests[dev]
- types-requests[tests]
- urllib3[all]
- urllib3[dev]
- urllib3[tests]
- uvicorn[all]
- uvicorn[dev]
- uvicorn[examples]
Used By
- apache-airflow-providers-apache-kafka
- localstack-ext
- rasa
- tinybird
- quixstreams
- port-ocean
- sentry-arroyo
- robotframework-confluentkafkalibrary
- mockafka-py
- taskbroker-client
- moose-lib
- apilogicserver
- rasa-pro
- tp-common
- holmesgpt
- django-kafka
- trustgraph-base
- airflow-provider-kafka
- gcn-kafka
- adc-streaming
- arrakis
- csle-collector
- flowfile
- dh-potluck
- confluent-kafka-helpers
- csle-ryu
- spakky-kafka
- sentry
- hagworm
- dyff-storage
- igwn-alert
- nodestream
- gwcelery
- beavers
- kafkian
- logprep
- nerdd-link
- shareddata
- swh-journal
- flask-kafka
- merlin-pyfunc-server
- horizon-data-core
- zuul
- hip-data-tools
- datafun-streaming
- kafi
- hspylib-kafman
- sgn-ligo
- dynamicio
- dwh-oppfolging