Helpers for aiokafka clients
Project description
# Kafka Helpers
A package with classes designed to make working with aiokafka simpler.
## Getting Started
```python
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
```
A package with classes designed to make working with aiokafka simpler.
## Getting Started
```python
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
```
Project details
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.3.tar.gz
(2.7 kB
view hashes)
Built Distribution
Close
Hashes for kafkahelpers-0.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 975fdc2d56a2b01a2df3e0c771d5caf578a2fe1eb1ebe207945c0cfff90f9406 |
|
MD5 | fffc1d6aefc0a336f584dcb3dcb49dbf |
|
BLAKE2b-256 | bec6c11646858ddc74315cf358008c622f3a574745e94c60c96e930698d6f1d8 |