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