confluent_avro
An Avro SerDe implementation that integrates with the confluent
Decision gist · record as of 2026-08-14
No—not recommended for new projects. The package is abandoned (last commit 2020-05-25) and will likely have unresolved compatibility issues with modern Confluent Schema Registry, Kafka client libraries, and Python versions. For active Kafka-Avro integration, use maintained alternatives. Only consider this if you are maintaining legacy code already using it and cannot migrate.AI-flagged interpretation of the facts on this page — verify before relying
Before you install
- Requires a running Confluent Schema Registry instance and a Kafka broker; last tested against Python 3.6, 3.7, 3.8.
- Low install friction with a pure-Python wheel.
- However, the package is abandoned—last commit was 2020-05-25, over 2276 days ago.
License · maintenance · safety
permissive license (permissive) — Licensed under Apache Software License (permissive). You may use, modify, and distribute the package freely, including in commercial applications, provided you retain license notices.
last release 2020-05-21 (2276 days) · last repo commit 2020-05-25 · 22 stars
0 known vulnerabilities (OSV.dev, 2026-08-14) · 83,274 downloads/mo, #14,085 on PyPI
Alternatives
Verify before relying
pip install confluent-avro
from confluent_avro import AvroKeyValueSerde, SchemaRegistry
from confluent_avro.schema_registry import HTTPBasicAuth
registry_client = SchemaRegistry(
"https://myschemaregistry.com",
HTTPBasicAuth("username", "password")
)
avroSerde = AvroKeyValueSerde(registry_client, "my-topic")
value = avroSerde.value.serialize({"field": "data"}, schema)- Compatibility with modern Confluent Schema Registry versions and recent Kafka client libraries.
- Whether cached schemas and exponential backoff retry logic function correctly with current infrastructure.
- Support for Python versions beyond 3.8 or compatibility with newer fastavro releases.
What it is and what it does
ConfluentAvro is a Python library that implements Avro serialization and deserialization according to the Confluent wire format specification. It integrates with Confluent Schema Registry to automatically register and fetch schemas, prepending the schema ID to Avro binary data before publishing to Kafka and retrieving it during consumption. The library caches schemas locally and reuses encoder/decoder instances to optimize performance across multiple records.
The package is built on fastavro for efficient Avro encoding and requests for HTTP communication with the schema registry. It supports both key and value serialization for Kafka messages and can integrate with any Kafka client library. However, the project has not been maintained since 2020-05-25, meaning it may lack compatibility with current versions of Confluent Schema Registry, Kafka clients, or Python runtime environments.
Use it for
- Serialize Python dictionaries to Avro format with automatic schema registration before publishing to Confluent Kafka topics.
- Deserialize Avro messages consumed from Kafka by fetching and caching schemas from the registry.
- Build Kafka producer and consumer applications that enforce schema compatibility through the Confluent Schema Registry.
- Cache schemas locally to reduce repeated registry lookups when processing high-volume Kafka streams.
Worth the install?
AI-flagged interpretation of the facts on this page. Verify before relying on it.
No—not recommended for new projects.
The package is abandoned (last commit 2020-05-25) and will likely have unresolved compatibility issues with modern Confluent Schema Registry, Kafka client libraries, and Python versions. For active Kafka-Avro integration, use maintained alternatives. Only consider this if you are maintaining legacy code already using it and cannot migrate.
Install
confluent-avro on PyPI
Before you install
Low install friction with a pure-Python wheel. However, the package is abandoned—last commit was 2020-05-25, over 2276 days ago. No recent maintenance or updates to address compatibility issues with modern Kafka clients or schema registry versions.
Requires a running Confluent Schema Registry instance and a Kafka broker; last tested against Python 3.6, 3.7, 3.8.
License in practice
Licensed under Apache Software License (permissive). You may use, modify, and distribute the package freely, including in commercial applications, provided you retain license notices.
Quickstart
pip install confluent-avro
from confluent_avro import AvroKeyValueSerde, SchemaRegistry
from confluent_avro.schema_registry import HTTPBasicAuth
registry_client = SchemaRegistry(
"https://myschemaregistry.com",
HTTPBasicAuth("username", "password")
)
avroSerde = AvroKeyValueSerde(registry_client, "my-topic")
value = avroSerde.value.serialize({"field": "data"}, schema)Verify before relying
- Compatibility with modern Confluent Schema Registry versions and recent Kafka client libraries.
- Whether cached schemas and exponential backoff retry logic function correctly with current infrastructure.
- Support for Python versions beyond 3.8 or compatibility with newer fastavro releases.
Package facts
| License | permissive license permissive |
| Python support | Supports the current Python release >=3.6 |
| Install friction | Low. Pure-Python wheel |
| Runtime dependencies | 3 packagesrequestsfastavropython-status |
| Maintenance | Abandoned 2,276 days since the last release |
| Last repo commit | |
| First released | |
| Downloads | 83,274 / month, #14,085 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 LicenseNatural Language :: EnglishOperating System :: OS IndependentProgramming Language :: Python :: 3 :: OnlyProgramming Language :: Python :: 3.6Programming Language :: Python :: 3.7Programming Language :: Python :: 3.8Topic :: Software DevelopmentTopic :: Software Development :: LibrariesTopic :: Software Development :: Libraries :: Python ModulesTyping :: Typed |
Evidence: confluent_avro-1.8.0-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 › “avro serialization kafka”
- confluent_avroSerializes and deserializes Avro data according to the Confluent wire…
- kafka-schema-registryIntegrates Kafka with Confluent Schema Registry to manage topic…
- py-avro-schemaGenerates Apache Avro schemas from Python dataclasses and Pydantic…
Give your agent the search over MCP, or paste the wish link into any chat.
More Software Development packages
Provides backported and experimental type hints for Python 3.9+, allowing use of newer typing features on older Python versions and enabling early experimentation with type system PEPs before they enter the standard library.
NumPy provides an N-dimensional array object and a comprehensive suite of mathematical, linear algebra, Fourier transform, and random number functions for scientific computing in Python.
FastAPI is a Python web framework for building REST APIs using type hints, with automatic request validation, serialization, and interactive API documentation.
Provides a way to document function parameters, class attributes, return types, and variables inline using Python's `Annotated` type hint syntax instead of traditional docstrings.
Typer builds command-line applications from Python functions using type hints, automatically generating help text, argument parsing, and shell completion.
Install it if you are building CLIs in Python.
Distlib provides low-level packaging utilities for building, distributing, and managing Python software—including metadata handling, version specifiers, wheel support, script installation, and dependency resolution.
See also aws-glue-schema-registry · confluent-kafka · kafka-schema-registry · python-schema-registry-client · avro-python3 · fastavro · sentry-kafka-schemas · avro · kafka · azure-schemaregistry-avroserializer