Helpers for aiokafka clients
Project description
Kafka Helpers
A package with classes designed to make working with aiokafka simpler.
Getting Started
from kafkahelpers import ReconnectingClient
kafka_client = aiokafka.AIOKafkaConsumer()
client = ReconnectingClient(kafka_client, "my_client")
async def my_func(client):
print("Hello World!")
event_loop.create_task(client.run(my_func))
Installing
The package is simple. All you need to do is install with your favorite package manager.
pip install kafkahelpers
Running the Tests
pytest
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
kafkahelpers-0.0.2.tar.gz
(2.7 kB
view details)
Built Distribution
File details
Details for the file kafkahelpers-0.0.2.tar.gz.
File metadata
- Download URL: kafkahelpers-0.0.2.tar.gz
- Upload date:
- Size: 2.7 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.11.0 pkginfo/1.4.2 requests/2.13.0 setuptools/40.0.0 requests-toolbelt/0.8.0 tqdm/4.23.4 CPython/3.6.4
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 27f68e43f9342749b1bf4ae8102aec8cc97678d504a0a0f197630a8fdda9f00d |
|
| MD5 | b46301de39715be833ecb173edc5e109 |
|
| BLAKE2b-256 | 96645e04ee5d5fc3c41231e812b493de66eb5e85648c263583554641901f2e7e |
File details
Details for the file kafkahelpers-0.0.2-py3-none-any.whl.
File metadata
- Download URL: kafkahelpers-0.0.2-py3-none-any.whl
- Upload date:
- Size: 7.3 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.11.0 pkginfo/1.4.2 requests/2.13.0 setuptools/40.0.0 requests-toolbelt/0.8.0 tqdm/4.23.4 CPython/3.6.4
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 03d06e9a296ff7cb2cc27ae145381a85d0f211e6618ca48d3513d23e6f0da6e2 |
|
| MD5 | 41007be9982133bfd1d4d5d03233a55c |
|
| BLAKE2b-256 | 797bd4ba36f593ef94741109c14dccc5dc4309ebf921a32d4ea3cad84b89d632 |
