Skip to main content

Asyn Python Rest Client to interact against Schema Registry Confluent Serverto manage Avro Schemas

Project description

Async Python Rest Client Schema Registry

Build Status GitHub license codecov Python Version

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:

Confluent Architecture

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

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page