{ "info": { "author": "Sankalp Jonna", "author_email": "sankalpjonna@gmail.com", "bugtrack_url": null, "classifiers": [], "description": "# kafkaesque\nThis A flask style kafka consumer. It is an extention of the KafkaConsumer from the kafka-python package available [`here`](https://github.com/dpkp/kafka-python) \n\n## Installation\n```sh\npip install kafkaesque\n```\n\n## writing a consumer looks like this\n\n```\nfrom kafkaesque import Kafkaesque\n\napp = Kafkaesque(\n bootstrap_servers=\",\".join([\n \"bs_1:9092\",\n \"bs_2:9093\",\n \"bs_3:9094\"\n ]),\n group_id=\"consumer-grp-id\"\n)\n\n@app.handle('test-topic')\ndef test_topic_handler(msg):\n print \"consumed {} from test-topic\".format(msg)\n\nif __name__ == \"__main__\":\n app.start()\n```\n\n## Author\n* **Sankalp Jonna**\n\nEmail me with any queries: [sankalpjonna@gmail.com](sankalpjonna@gmail.com).\n\n", "description_content_type": "", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/sankalpjonn/kafkaesque", "keywords": "kafka,consumer,kafkaesque,flask,simple,consumer,flask style,decorator", "license": "MIT", "maintainer": "", "maintainer_email": "", "name": "kafkaesque", "package_url": "https://pypi.org/project/kafkaesque/", "platform": "", "project_url": "https://pypi.org/project/kafkaesque/", "project_urls": { "Homepage": "https://github.com/sankalpjonn/kafkaesque" }, "release_url": "https://pypi.org/project/kafkaesque/1.0/", "requires_dist": [ "kafka-python" ], "requires_python": "", "summary": "an easy to use kafka consumer that extends kafka-python, but follows the style of the flask server", "version": "1.0" }, "last_serial": 4057334, "releases": { "1.0": [ { "comment_text": "", "digests": { "md5": "de896d38d3057662bf00ac1b0cc81143", "sha256": "ca732dc17d4e07061fd07cb34c82c9527d0de5afa8ea678507be140e48518b1f" }, "downloads": -1, "filename": "kafkaesque-1.0-py2.7.egg", "has_sig": false, "md5_digest": "de896d38d3057662bf00ac1b0cc81143", "packagetype": "bdist_egg", "python_version": "2.7", "requires_python": null, "size": 4195, "upload_time": "2018-07-13T10:13:50", "url": "https://files.pythonhosted.org/packages/be/76/a3b89d942748e1a4f8b3f25813a046812db31ab9efeb635673c7d44e3ad4/kafkaesque-1.0-py2.7.egg" }, { "comment_text": "", "digests": { "md5": "473920cffdd66963e985fed4453cd2b0", "sha256": "4fe3cf066ad31ea0640eb7c889a15b10a325c3cf1f8e44cd5e13a90e71e1f76b" }, "downloads": -1, "filename": "kafkaesque-1.0-py2-none-any.whl", "has_sig": false, "md5_digest": "473920cffdd66963e985fed4453cd2b0", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 3808, "upload_time": "2018-07-13T10:13:49", "url": "https://files.pythonhosted.org/packages/5e/14/200712cd6eff8b01c97f1da5acc5c8fb4bd996deea4e2420ded5fdb5b99f/kafkaesque-1.0-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "17a0697937b665e745a6e9afa26f0631", "sha256": "8ceeebdf31dfb11019e6d80d263be0ad2a1bdffc3b88fd94382e2a7896764936" }, "downloads": -1, "filename": "kafkaesque-1.0.tar.gz", "has_sig": false, "md5_digest": "17a0697937b665e745a6e9afa26f0631", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2217, "upload_time": "2018-07-13T10:13:51", "url": "https://files.pythonhosted.org/packages/3c/11/b4172a8f24574d571169da1f9e7b73a421a921f097976d84ac1f2bf027a1/kafkaesque-1.0.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "de896d38d3057662bf00ac1b0cc81143", "sha256": "ca732dc17d4e07061fd07cb34c82c9527d0de5afa8ea678507be140e48518b1f" }, "downloads": -1, "filename": "kafkaesque-1.0-py2.7.egg", "has_sig": false, "md5_digest": "de896d38d3057662bf00ac1b0cc81143", "packagetype": "bdist_egg", "python_version": "2.7", "requires_python": null, "size": 4195, "upload_time": "2018-07-13T10:13:50", "url": "https://files.pythonhosted.org/packages/be/76/a3b89d942748e1a4f8b3f25813a046812db31ab9efeb635673c7d44e3ad4/kafkaesque-1.0-py2.7.egg" }, { "comment_text": "", "digests": { "md5": "473920cffdd66963e985fed4453cd2b0", "sha256": "4fe3cf066ad31ea0640eb7c889a15b10a325c3cf1f8e44cd5e13a90e71e1f76b" }, "downloads": -1, "filename": "kafkaesque-1.0-py2-none-any.whl", "has_sig": false, "md5_digest": "473920cffdd66963e985fed4453cd2b0", "packagetype": "bdist_wheel", "python_version": "py2", "requires_python": null, "size": 3808, "upload_time": "2018-07-13T10:13:49", "url": "https://files.pythonhosted.org/packages/5e/14/200712cd6eff8b01c97f1da5acc5c8fb4bd996deea4e2420ded5fdb5b99f/kafkaesque-1.0-py2-none-any.whl" }, { "comment_text": "", "digests": { "md5": "17a0697937b665e745a6e9afa26f0631", "sha256": "8ceeebdf31dfb11019e6d80d263be0ad2a1bdffc3b88fd94382e2a7896764936" }, "downloads": -1, "filename": "kafkaesque-1.0.tar.gz", "has_sig": false, "md5_digest": "17a0697937b665e745a6e9afa26f0631", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 2217, "upload_time": "2018-07-13T10:13:51", "url": "https://files.pythonhosted.org/packages/3c/11/b4172a8f24574d571169da1f9e7b73a421a921f097976d84ac1f2bf027a1/kafkaesque-1.0.tar.gz" } ] }