Async Python Rest Client Schema Registry

Async Python Rest Client 用于与 schema-registry confluent server 交互以管理 Avro Schema 资源。

要求

python 3.6+, fastavro, requests-async, aiofiles

安装

pip install async-python-schema-registry-client

客户端API、序列化和Schema服务器描述

文档： https://marcosschroh.github.io/async-python-schema-registry-client.io

何时使用此库

通常，我们有一个场景，其中我们有一些生产者/消费者，它们将事件序列化/反序列化以从/向Kafka主题发送/接收。在这个图中，我们可以想象一个 Faust 或 Flink 应用程序接收/发送消息（使用Avro模式编码）

Avro模式 需要维护，并且还需要使用它来编码/解码事件。在这种情况下，此库方便使用。

摘要:

• 当我们想要构建一个用于管理 Avro Schemas 的应用程序（注册、更新兼容性、删除旧模式等）时
• 当我们有一个需要将事件序列化/反序列化以发送/接收到/从Kafka主题的过程时

开发

测试是在使用 docker compose 对 Schema Server 进行，因此您需要安装 Docker 和 Docker Compose。

./scripts/test

代码校验

./scripts/lint