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 use this library?
Usually, we have a situacion like this:
So, our producers/consumers have to serialize/deserialize messages every time that they send/receive from Kafka topics. In this picture, we can imagine a Faust
application receiving messages (encoded with an Avro schema) and we want to deserialize them, so we can ask the schema server
to do that for us. In this scenario, the MessageSerializer
is perfect.
Also, could be a use case that we would like to have an Application only to administrate Avro Schemas
(register, update compatibilities, delete old schemas, etc.), so the SchemaRegistryClient
is perfect.
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-0.2.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 721ffaeb3643a05394555153d32bb4b0302db096e3c9cd52e0c527c84a182c4d |
|
MD5 | 9f08bf58dfe693a2ff8bda22e8faf6a7 |
|
BLAKE2b-256 | e40f3e334e28a22c12979153089267eff06c40e9c82c6cc349eef9d283890c14 |