Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
AvroConsumer
✓ from confluent_avro import AvroConsumer
✗ from confluent_avro import AvroConsumer
AvroProducer
✓ from confluent_avro import AvroProducer
SchemaRegistryClient
✓ from confluent_avro.schema_registry import SchemaRegistryClient
Basic AvroProducer example with schema registry.
import os
from confluent_avro import AvroProducer
from confluent_kafka import avro
def delivery_report(err, msg):
if err is not None:
print('Delivery failed:', err)
else:
print('Message delivered to', msg.topic())
conf = {
'bootstrap.servers': 'localhost:9092',
'schema.registry.url': 'http://localhost:8081'
}
# Define Avro schema
value_schema = avro.loads('{"type": "record", "name": "User", "fields": [{"name": "name", "type": "string"}]}')
producer = AvroProducer(conf, default_value_schema=value_schema)
producer.produce(topic='users', value={'name': 'Alice'}, callback=delivery_report)
producer.flush()
Upgrade
Version history
1.8.0latest on PyPI · released May 21, 2020
Audit
Dependencies
confluent-kafkarequiredconsumer/producer integration
avro-python3requiredAvro schema handling
requestsrequiredHTTP calls to Schema Registry
fastavrooptionalfast Avro decoding (optional)