Skip to main content

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
```


Project details


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 details)

Uploaded Source

Built Distribution

kafkahelpers-0.0.3-py3-none-any.whl (7.3 kB view details)

Uploaded Python 3

File details

Details for the file kafkahelpers-0.0.3.tar.gz.

File metadata

  • Download URL: kafkahelpers-0.0.3.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.21.0 setuptools/40.0.0 requests-toolbelt/0.8.0 tqdm/4.23.4 CPython/3.6.4

File hashes

Hashes for kafkahelpers-0.0.3.tar.gz
Algorithm Hash digest
SHA256 6cc2a70928452004d7dfc0f43a2b0620473c37387fb5e70d7d4dc0fed7a134c8
MD5 24836017d55920169573b7b8d72be947
BLAKE2b-256 a5f3f9477b755b1b2e0746f22b80d22bc80898b05688048e37bfde98b5daac9f

See more details on using hashes here.

File details

Details for the file kafkahelpers-0.0.3-py3-none-any.whl.

File metadata

  • Download URL: kafkahelpers-0.0.3-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.21.0 setuptools/40.0.0 requests-toolbelt/0.8.0 tqdm/4.23.4 CPython/3.6.4

File hashes

Hashes for kafkahelpers-0.0.3-py3-none-any.whl
Algorithm Hash digest
SHA256 975fdc2d56a2b01a2df3e0c771d5caf578a2fe1eb1ebe207945c0cfff90f9406
MD5 fffc1d6aefc0a336f584dcb3dcb49dbf
BLAKE2b-256 bec6c11646858ddc74315cf358008c622f3a574745e94c60c96e930698d6f1d8

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page