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

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

quintoandar_kafka-2.0.0.tar.gz (3.5 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

quintoandar_kafka-2.0.0-py3-none-any.whl (4.9 kB view details)

Uploaded Python 3

File details

Details for the file quintoandar_kafka-2.0.0.tar.gz.

File metadata

  • Download URL: quintoandar_kafka-2.0.0.tar.gz
  • Upload date:
  • Size: 3.5 kB
  • Tags: Source
  • Uploaded using 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

File hashes

Hashes for quintoandar_kafka-2.0.0.tar.gz
Algorithm Hash digest
SHA256 de4f0c36a46648194548fd176acf7b1ddb59febf70facf0f32f63d3b58856ed6
MD5 8d55443912cbcd92105d461910b8f301
BLAKE2b-256 fe5e2a18dfbef228aa602fe251e0d10b111aebf664af9738e59a0f3823b17c17

See more details on using hashes here.

File details

Details for the file quintoandar_kafka-2.0.0-py3-none-any.whl.

File metadata

  • Download URL: quintoandar_kafka-2.0.0-py3-none-any.whl
  • Upload date:
  • Size: 4.9 kB
  • Tags: Python 3
  • Uploaded using 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

File hashes

Hashes for quintoandar_kafka-2.0.0-py3-none-any.whl
Algorithm Hash digest
SHA256 9d897ea04b6ce5ff9b219b8c995bb34d09e4bd69bd2ae8fcf2b7c2adb507397d
MD5 46f8068c533d5c4eec1c679e136c3f71
BLAKE2b-256 14b953920c92aa30e9f5c13df4fd820eac8306cefc580c1727626f878603720d

See more details on using hashes here.

Release history Release notifications | RSS feed

This release

2.0.0 This release

2 files

Supported by

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