{
    "info": {
        "author": "Wei Zhang",
        "author_email": "zhangw1.2011@gmail.com",
        "bugtrack_url": null,
        "classifiers": [
            "License :: OSI Approved :: MIT License",
            "Operating System :: OS Independent",
            "Programming Language :: Python :: 3"
        ],
        "description": "### A wrapper for [kafka-python](https://kafka-python.readthedocs.io/en/master/usage.html)\n\n#### Installation\n\nInstall using pip:\n```shell\npip install kafkaPythonWrapper\n```\nInstall from Github:\n```shell\ngit clone https://github.com/Weizhang2017/pythonKakfaWrapper\ncd pythonKakfaWrapper \npython setup.py install\n```\n\n\n#### CLI\n\n###### Usage\n```shell\nusage: kafkaPython [-h] --type type --topic topic [--group_id group_id]\n                   --bootstrap_server bootstrap_server [--value value]\n                   [--key key]\nRequired arguments:\n  --type              type of kafka client, consumer or producer\n  --topic             specify a topic for Kafka\n  --bootstrap_server  specify a bootstrap server for Kafka\n\nOptional arguments:\n--group_id       specify a group ID for Kafka consumer\n--value          specify a value to send to Kafka\n--key            specify a key to send to Kafka\n```\nThe **client type** is either producer or consumer. If the type is producer, the flag **value** is required while **key** is optional. If the type is consumer, the flag **group_id** is required.\n\n\n###### Simple Examples:\n\nSend a message to Kafka\n```shell\nkafkaPython --type producer --topic test --bootstrap_server 'localhost:9092' --key test_key --value test_value\n``` \n\nPrint messages from Kafka\n```shell\nkafkaPython --type consumer --bootstrap_server 'localhost:9092' --topic test --group_id 1\n```\n\n#### API\n###### Usage\nSend the output of a function to Kafka\n```python\nfrom kafkaPythonWrapper import MessageSender\n\nmessage_sender = MessageSender(topic='test')\n\n@message_sender.send_sync()\ndef produce_message():\n    key, value = 'email_address', 'wzhang@leadbook.com'\n    print(f'{key}: {value}')\n    yield key, value\n```\n\nReceive and print messages from Kafka\n```python\nfrom kafkaPythonWrapper import MessageCollector\n\nmessage_collector = MessageCollector(topic='test', group_id='1')\n\n@message_collector.consume\ndef print_message(**kwargs):\n    print(kwargs)\n```\n\nClose producer or consumer\n```python\nmessage_sender.close()\nmessage_collector.close()\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/Weizhang2017/pythonKakfaWrapper",
        "keywords": "",
        "license": "",
        "maintainer": "",
        "maintainer_email": "",
        "name": "kafkaPythonWrapper",
        "package_url": "https://pypi.org/project/kafkaPythonWrapper/",
        "platform": "",
        "project_url": "https://pypi.org/project/kafkaPythonWrapper/",
        "project_urls": {
            "Homepage": "https://github.com/Weizhang2017/pythonKakfaWrapper"
        },
        "release_url": "https://pypi.org/project/kafkaPythonWrapper/0.1.3/",
        "requires_dist": [
            "kafka-python"
        ],
        "requires_python": ">=3.7",
        "summary": "A wrapper for kafka-python",
        "version": "0.1.3"
    },
    "last_serial": 5894567,
    "releases": {
        "0.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "095f7c9c0c724b34ec895708ae0f63b2",
                    "sha256": "4e3622506cc5b55f2b4de8baaa357ba1147fdae86d26f7a0d38257dc6151fe7c"
                },
                "downloads": -1,
                "filename": "kafkaPythonWrapper-0.1-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "095f7c9c0c724b34ec895708ae0f63b2",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": ">=3.7",
                "size": 6278,
                "upload_time": "2019-09-16T09:26:14",
                "url": "https://files.pythonhosted.org/packages/4c/91/0d85d6de9656d681a6ba51774f958f94bfa181cc6cd78a667117e6c656ff/kafkaPythonWrapper-0.1-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "3937198d0ca3a26cad74a65c812fb75e",
                    "sha256": "00a5a6857ccdb613733422d3925e28c2feb0d9d8b024cc38f32d513c6efa2b49"
                },
                "downloads": -1,
                "filename": "kafkaPythonWrapper-0.1.tar.gz",
                "has_sig": false,
                "md5_digest": "3937198d0ca3a26cad74a65c812fb75e",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": ">=3.7",
                "size": 4082,
                "upload_time": "2019-09-16T09:26:32",
                "url": "https://files.pythonhosted.org/packages/a5/30/5c1c33f0ce0876d816bf4a13a504a8e88d7ec145f33e1ff448249528c94d/kafkaPythonWrapper-0.1.tar.gz"
            }
        ],
        "0.1.2": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "f53a9cf2d3658fa729909fd06485d103",
                    "sha256": "e24765f1b9d8e56fdc70f90adff4e4a6f6849dece19a059680d32670882db4b0"
                },
                "downloads": -1,
                "filename": "kafkaPythonWrapper-0.1.2-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "f53a9cf2d3658fa729909fd06485d103",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": ">=3.7",
                "size": 6404,
                "upload_time": "2019-09-23T09:38:01",
                "url": "https://files.pythonhosted.org/packages/f5/b2/45f605a062996642f987059b8f573eb38ab58a1b3215016d97c57314e95f/kafkaPythonWrapper-0.1.2-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "361f2a10c4fb54f829960a00c93a3b6f",
                    "sha256": "cc763a7bd97be35d510a781f54094a39c655908a07d359c9121b0e2cbd4428f5"
                },
                "downloads": -1,
                "filename": "kafkaPythonWrapper-0.1.2.tar.gz",
                "has_sig": false,
                "md5_digest": "361f2a10c4fb54f829960a00c93a3b6f",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": ">=3.7",
                "size": 4190,
                "upload_time": "2019-09-23T09:38:03",
                "url": "https://files.pythonhosted.org/packages/e9/a7/ab1b9c9e528f10e28822cccc0a720203a576e6f9ba442d23ec9cf0d8484b/kafkaPythonWrapper-0.1.2.tar.gz"
            }
        ],
        "0.1.3": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "c3accd40c39a6bbb8dcdc825c3e7c2a0",
                    "sha256": "c9f4dbecd85c2e059a0e6c9a61a83e73601f06d5696f18210b7a52622fcd586c"
                },
                "downloads": -1,
                "filename": "kafkaPythonWrapper-0.1.3-py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "c3accd40c39a6bbb8dcdc825c3e7c2a0",
                "packagetype": "bdist_wheel",
                "python_version": "py3",
                "requires_python": ">=3.7",
                "size": 6415,
                "upload_time": "2019-09-27T07:12:34",
                "url": "https://files.pythonhosted.org/packages/4f/e2/9f35cbb8c1ed6979a31de30c15a0831b7131533c5adefb17d8f0ad313c14/kafkaPythonWrapper-0.1.3-py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "deac21bb11babf0d3eb18fa05d1aec57",
                    "sha256": "02141e41ba00d6de3e313bdeadc822acad00478e0cfa15726391bfdfb71b8558"
                },
                "downloads": -1,
                "filename": "kafkaPythonWrapper-0.1.3.tar.gz",
                "has_sig": false,
                "md5_digest": "deac21bb11babf0d3eb18fa05d1aec57",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": ">=3.7",
                "size": 4227,
                "upload_time": "2019-09-27T07:12:36",
                "url": "https://files.pythonhosted.org/packages/d4/14/e176d02fa51bfd88384943cf7638dadc87f54896f10ad42a0c628ae17099/kafkaPythonWrapper-0.1.3.tar.gz"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "c3accd40c39a6bbb8dcdc825c3e7c2a0",
                "sha256": "c9f4dbecd85c2e059a0e6c9a61a83e73601f06d5696f18210b7a52622fcd586c"
            },
            "downloads": -1,
            "filename": "kafkaPythonWrapper-0.1.3-py3-none-any.whl",
            "has_sig": false,
            "md5_digest": "c3accd40c39a6bbb8dcdc825c3e7c2a0",
            "packagetype": "bdist_wheel",
            "python_version": "py3",
            "requires_python": ">=3.7",
            "size": 6415,
            "upload_time": "2019-09-27T07:12:34",
            "url": "https://files.pythonhosted.org/packages/4f/e2/9f35cbb8c1ed6979a31de30c15a0831b7131533c5adefb17d8f0ad313c14/kafkaPythonWrapper-0.1.3-py3-none-any.whl"
        },
        {
            "comment_text": "",
            "digests": {
                "md5": "deac21bb11babf0d3eb18fa05d1aec57",
                "sha256": "02141e41ba00d6de3e313bdeadc822acad00478e0cfa15726391bfdfb71b8558"
            },
            "downloads": -1,
            "filename": "kafkaPythonWrapper-0.1.3.tar.gz",
            "has_sig": false,
            "md5_digest": "deac21bb11babf0d3eb18fa05d1aec57",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": ">=3.7",
            "size": 4227,
            "upload_time": "2019-09-27T07:12:36",
            "url": "https://files.pythonhosted.org/packages/d4/14/e176d02fa51bfd88384943cf7638dadc87f54896f10ad42a0c628ae17099/kafkaPythonWrapper-0.1.3.tar.gz"
        }
    ]
}