Kafkit
Kafkit helps you write Kafka producers and consumers in Python with asyncio:
-
Kafkit provides a client for the Confluent Schema Registry's HTTP API. The
RegistryApiclient includes both high-level methods for managing subjects and schemas in a Registry, and direct low-level access to HTTP methods (GET, POST, PUT, PATCH, and DELETE). The high-level methods use caching so you can use the client as an integral part of your application's schema management.RegistryApiis implemented around aiohttp, but since the base class is designed with a sans IO architecture, a Registry client can be implemented with any asyncio HTTP library. -
Kafkit provides Avro message serializers and deserializers that integrate with the Confluent Schema Registry:
Deserializer,Serializer, andPolySerializer. -
The
RecordNameSchemaManageris a streamlined tool for serializing messages using the schemas maintained by your app, while also integrating with the Confluent Schema Registry. -
The
kafkit.sslmodule helps you connect to SSL-secured Kafka brokers.
Learn more about Kafkit at https://kafkit.lsst.io.
2 maintainers
Metadata
2 maintainers
Release files for kafkit 0.3.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| kafkit-0.3.1.tar.gz | 49.0 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| kafkit-0.3.1-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 70.0 kB
Release files / kafkit-0.3.1.tar.gz
| Download URL | kafkit-0.3.1.tar.gz |
|---|---|
| Size | 49.0 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
b16dc5f3c698afdc5771636f13f8a418d48be931519fdc395a738926ea3d8254
|
|
BLAKE2b-256 checksum How to use checksums |
af31909171bffb2c0fae51961fa6023525c3279e19060e55c0b330a17fa16c19
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
uv/0.7.3
|
Release files / kafkit-0.3.1-py3-none-any.whl
| Download URL | kafkit-0.3.1-py3-none-any.whl |
|---|---|
| Size | 21.0 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
e9f998a839a37bc0cbff88cb17b902e4efe15cb2171a2e71364e8137c13235f9
|
|
BLAKE2b-256 checksum How to use checksums |
a69e406a876967591a82af90da403483ad64a48efcd3a97611d99812c713cf4c
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
uv/0.7.3
|
