Kafkit helps you write Kafka producers and consumers in Python with asyncio.
Project description
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.
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
File details
Details for the file kafkit-0.2.0rc1.tar.gz.
File metadata
- Download URL: kafkit-0.2.0rc1.tar.gz
- Upload date:
- Size: 45.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.1 CPython/3.9.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | b69ee22c496c396f7c82c3d0d8d216ae080d3f724ebf159e755811e948d9a869 |
|
| MD5 | aaa262f66a19d19611951dc298aa150c |
|
| BLAKE2b-256 | 976aedf1c5999bba43e416a94bd704a892d1ab03e54518eb07d04077c61a9393 |
File details
Details for the file kafkit-0.2.0rc1-py3-none-any.whl.
File metadata
- Download URL: kafkit-0.2.0rc1-py3-none-any.whl
- Upload date:
- Size: 20.4 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.1 CPython/3.9.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 1a9834dc5d69a129ea40f06642ca647c870e9dc3bb9ca6d5198e9942793df489 |
|
| MD5 | 2cb177f57a2ea22baf6d513ba3c36465 |
|
| BLAKE2b-256 | ee4f551c201cade677d507bb7c7b76156ecf4116d7c747c1afc0d0d7679e5051 |
