---
id: confluent-avro
version: "1.8.0"
license: unclear
license_treatment: permissive
maintenance: abandoned
---

# confluent_avro — An Avro SerDe implementation that integrates with the confluent

License: permissive · Maintenance: abandoned · Downloads: 83.3K/mo

## 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 above — verify before relying.

Serializes and deserializes Avro data according to the Confluent wire format, integrating with Confluent Schema Registry to manage schemas for Kafka applications.

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

pip install confluent-avro
uv add confluent-avro
poetry add confluent-avro

## Installing confluent_avro

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.

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)

Requires a running Confluent Schema Registry instance and a Kafka broker; last tested against Python 3.6, 3.7, 3.8.

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: not declared (permissive)
- Python support: supports_current
- Install friction: low
- Maintenance: abandoned
- Downloads: 83.3K/month (top 15,000 on PyPI)
- Known vulnerabilities: none known

## Tags

avro serialization kafka, confluent schema registry client, avro serde confluent wire format, kafka avro serializer deserializer, confluent avro python, schema registry integration, avro kafka producer consumer, kafka, avro, schema-registry

[View on SkillFed](https://skillfed.io/packages/confluent-avro) · [View on PyPI](https://pypi.org/project/confluent-avro/)