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.1.tar.gz
(2.6 kB
view hashes)
Built Distribution
Close
Hashes for kafkahelpers-0.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ad3ad326744fb62a566296b076f6fbd1de83680d9f9fec5540856a5a668fa39f |
|
MD5 | fb80954d437a6d398e662b583c86a4ee |
|
BLAKE2b-256 | 69eb9454dfed5b7b6e7a39778b0cfcdadc7ee6694954e2b1163aee4b4bfc3f70 |