kaflit 帮助您使用 asyncio 在 Python 中编写 Kafka 生产者和消费者。
项目描述
kaflit
kaflit 帮助您使用 asyncio 在 Python 中编写 Kafka 生产者和消费者
-
kaflit 提供了 Confluent Schema Registry 的 HTTP API 客户端。`RegistryApi` 客户端包含用于在注册表中管理主题和模式的 高级方法，以及直接访问 HTTP 方法（GET、POST、PUT、PATCH 和 DELETE）。高级方法使用缓存，因此您可以将其作为应用程序模式管理的重要组成部分来使用。`RegistryApi` 基于 aiohttp 实现，但由于基类设计为 sans IO 架构，因此可以使用任何 asyncio HTTP 库实现注册表客户端。
-
Kafkit提供与康纳夫（Confluent）模式注册表（Schema Registry）集成的Avro消息序列化和反序列化器：包括
反序列化器、序列化器和多序列化器。 -
RecordNameSchemaManager是一个简化工具，用于使用您的应用程序维护的模式序列化消息，同时与康纳夫模式注册表集成。 -
kafkit.ssl模块帮助您连接到SSL加密的Kafka代理。
更多关于Kafkit的信息，请访问https://kafkit.lsst.io。
下载文件
下载适合您平台的文件。如果您不确定选择哪个，请了解更多关于安装包的信息。
源代码分发
kafkit-0.3.0.tar.gz (46.6 kB 查看哈希值)
构建分发
kafkit-0.3.0-py3-none-any.whl (21.1 kB 查看哈希值)
