Asyn Python Rest Client to interact against Schema Registry Confluent Serverto manage Avro Schemas
Project description
Async Python Rest Client Schema Registry
Async Python Rest Client to interact against schema-registry confluent server to manage Avro Schemas resources.
Requirements
python 3.6+, fastavro, requests-async, aiofiles
Installation
pip install async-python-schema-registry-client
Client API, Serializer and Schema Server description
Documentation: https://marcosschroh.github.io/async-python-schema-registry-client.io
When to use this library
Usually, we have a situacion in which we have producers/consumers that serialize/deserialize events to send/receive from Kafka topics. In this picture, we can imagine a Faust
or Flink
application receiving/sending messages (encoded with an Avro schema)
Avro schemas
have to be maintained and also need to be used to encode/decode events. On those situation this library is convenient to use.
Summary:
- When we want to build an application to administrate
Avro Schemas
(register, update compatibilities, delete old schemas, etc.) - When we have a process that needs to serialize/deserialize events to send/receive to/from a kafka topics
Development
The tests are run against the Schema Server
using docker compose
, so you will need
Docker
and Docker Compose
installed.
./scripts/test
Lint code:
./scripts/lint
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Hashes for async-python-schema-registry-client-1.0.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5389773bb4811432af393957bdf5ae565af6192daa45efca185305ce21db1193 |
|
MD5 | c0aebf14b45858ad2572582052bf79a3 |
|
BLAKE2b-256 | 4f3ea176d1ade6c88b8ae74342b133f0b5280f648ca730f34fde5ebb6fb5d8ef |