Skip to main content

Build Status

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:

  1. Python 3.6.8

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)

Source distribution for quintoandar-kafka 2.0.0
File Size Uploaded
quintoandar_kafka-2.0.0.tar.gz 3.5 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for quintoandar-kafka 2.0.0
File Interpreter ABI Platform
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

Release history Release notifications | RSS feed

This release

2.0.0 This release

2 release files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page