{ "info": { "author": "QuintoAndar", "author_email": "rodrigo.oliveira@quintoandar.com.br", "bugtrack_url": null, "classifiers": [ "License :: OSI Approved :: MIT License", "Operating System :: OS Independent", "Programming Language :: Python :: 3" ], "description": "[![Build Status](https://travis-ci.org/quintoandar/python-kafka.svg?branch=master)](https://travis-ci.org/quintoandar/python-kafka)\n\n# QuintoAndar Kafka Python Library\n\nQuintoAndar's kafka-python lib wrapper with additional functionalities.\n\n## KafkaIdempotentConsumer\n\nA simple wrapper for kafka-python lib that uses redis to check duplicate events.\n\n### Configuration\n\n| Name | Description |\n| ----------------- | -------------------------------------------- |\n| group_id | The consumer group id |\n| bootstrap_servers | The bootstrap servers |\n| redis_host | The topic to consume from |\n| redis_port | The function that processes the event |\n| idempotent_key | Function which extract an unique identifier from the event |\n\n\nSee [examples](/examples)\n\n## Development\n\n### Environment\n\nAt the bare minimum you'll need the following for your development\nenvironment:\n\n1. [Python 3.6.8](http://www.python.org/)\n\nIt is strongly recommended to also install and use [pyenv](https://github.com/pyenv/pyenv):\n\n - [pyenv-installer](https://github.com/pyenv/pyenv-installer)\n\nThis tool eases the burden of dealing with virtualenvs and having to activate and\ndeactivate'em by hand. Once you run `pyenv local my-project-venv` the directory you're\nin will be bound to the `my-project-venv` virtual environment and then you will have\nnever to bother again activating the correct venv.\n\n### Getting Started\n\n#### 1. Clone the project:\n\n```bash\ngit clone git@github.com:quintoandar/kafka-python.git\ncd kafka-python\n```\n\n#### 2. Setup the python environment for the project:\n\n```bash\nmake environment\n```\n\n#### 3. Install dependencies\n\nYou can just the make recipe:\n\n```bash\nmake install\n```\n\n\n", "description_content_type": "text/markdown", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/quintoandar/kafka-python", "keywords": "", "license": "", "maintainer": "", "maintainer_email": "", "name": "quintoandar-kafka", "package_url": "https://pypi.org/project/quintoandar-kafka/", "platform": "", "project_url": "https://pypi.org/project/quintoandar-kafka/", "project_urls": { "Homepage": "https://github.com/quintoandar/kafka-python" }, "release_url": "https://pypi.org/project/quintoandar-kafka/2.0.0/", "requires_dist": [ "redis (==2.10.6)", "retrying (==1.3.3)", "kafka-python (==1.4.6)" ], "requires_python": "", "summary": "Checks messages to avoid reprocessing events.", "version": "2.0.0" }, "last_serial": 5837838, "releases": { "2.0.0": [ { "comment_text": "", "digests": { "md5": "46f8068c533d5c4eec1c679e136c3f71", "sha256": "9d897ea04b6ce5ff9b219b8c995bb34d09e4bd69bd2ae8fcf2b7c2adb507397d" }, "downloads": -1, "filename": "quintoandar_kafka-2.0.0-py3-none-any.whl", "has_sig": false, "md5_digest": "46f8068c533d5c4eec1c679e136c3f71", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 4891, "upload_time": "2019-09-16T19:19:37", "url": "https://files.pythonhosted.org/packages/14/b9/53920c92aa30e9f5c13df4fd820eac8306cefc580c1727626f878603720d/quintoandar_kafka-2.0.0-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "8d55443912cbcd92105d461910b8f301", "sha256": "de4f0c36a46648194548fd176acf7b1ddb59febf70facf0f32f63d3b58856ed6" }, "downloads": -1, "filename": "quintoandar_kafka-2.0.0.tar.gz", "has_sig": false, "md5_digest": "8d55443912cbcd92105d461910b8f301", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3520, "upload_time": "2019-09-16T19:19:40", "url": "https://files.pythonhosted.org/packages/fe/5e/2a18dfbef228aa602fe251e0d10b111aebf664af9738e59a0f3823b17c17/quintoandar_kafka-2.0.0.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "46f8068c533d5c4eec1c679e136c3f71", "sha256": "9d897ea04b6ce5ff9b219b8c995bb34d09e4bd69bd2ae8fcf2b7c2adb507397d" }, "downloads": -1, "filename": "quintoandar_kafka-2.0.0-py3-none-any.whl", "has_sig": false, "md5_digest": "46f8068c533d5c4eec1c679e136c3f71", "packagetype": "bdist_wheel", "python_version": "py3", "requires_python": null, "size": 4891, "upload_time": "2019-09-16T19:19:37", "url": "https://files.pythonhosted.org/packages/14/b9/53920c92aa30e9f5c13df4fd820eac8306cefc580c1727626f878603720d/quintoandar_kafka-2.0.0-py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "8d55443912cbcd92105d461910b8f301", "sha256": "de4f0c36a46648194548fd176acf7b1ddb59febf70facf0f32f63d3b58856ed6" }, "downloads": -1, "filename": "quintoandar_kafka-2.0.0.tar.gz", "has_sig": false, "md5_digest": "8d55443912cbcd92105d461910b8f301", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3520, "upload_time": "2019-09-16T19:19:40", "url": "https://files.pythonhosted.org/packages/fe/5e/2a18dfbef228aa602fe251e0d10b111aebf664af9738e59a0f3823b17c17/quintoandar_kafka-2.0.0.tar.gz" } ] }