QuintoAndar Kafka Python Library
QuintoAndar's kafka-python lib wrapper with additional functionalities.
KafkaIdempotentConsumer
A simple wrapper for kafka-python lib that uses redis to check duplicate events.
Configuration
| Name | Description |
|---|---|
| group_id | The consumer group id |
| bootstrap_servers | The bootstrap servers |
| redis_host | The topic to consume from |
| redis_port | The function that processes the event |
| idempotent_key | Function which extract an unique identifier from the event |
See examples
Development
Environment
At the bare minimum you'll need the following for your development environment:
It is strongly recommended to also install and use pyenv:
This tool eases the burden of dealing with virtualenvs and having to activate and
deactivate'em by hand. Once you run pyenv local my-project-venv the directory you're
in will be bound to the my-project-venv virtual environment and then you will have
never to bother again activating the correct venv.
Getting Started
1. Clone the project:
git clone git@github.com:quintoandar/kafka-python.git
cd kafka-python
2. Setup the python environment for the project:
make environment
3. Install dependencies
You can just the make recipe:
make install
Metadata
Release files for quintoandar-kafka 2.0.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| quintoandar_kafka-2.0.0.tar.gz | 3.5 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| quintoandar_kafka-2.0.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 8.4 kB
Release files / quintoandar_kafka-2.0.0.tar.gz
| Download URL | quintoandar_kafka-2.0.0.tar.gz |
|---|---|
| Size | 3.5 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
de4f0c36a46648194548fd176acf7b1ddb59febf70facf0f32f63d3b58856ed6
|
|
BLAKE2b-256 checksum How to use checksums |
fe5e2a18dfbef228aa602fe251e0d10b111aebf664af9738e59a0f3823b17c17
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.14.0 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.2.0 requests-toolbelt/0.9.1 tqdm/4.35.0 CPython/3.6.8
|
Release files / quintoandar_kafka-2.0.0-py3-none-any.whl
| Download URL | quintoandar_kafka-2.0.0-py3-none-any.whl |
|---|---|
| Size | 4.9 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
9d897ea04b6ce5ff9b219b8c995bb34d09e4bd69bd2ae8fcf2b7c2adb507397d
|
|
BLAKE2b-256 checksum How to use checksums |
14b953920c92aa30e9f5c13df4fd820eac8306cefc580c1727626f878603720d
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/1.14.0 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.2.0 requests-toolbelt/0.9.1 tqdm/4.35.0 CPython/3.6.8
|