{
    "info": {
        "author": "Carlo Mazzaferro",
        "author_email": "carlo.mazzaferro@gmail.com",
        "bugtrack_url": null,
        "classifiers": [
            "Development Status :: 4 - Beta",
            "Programming Language :: Python"
        ],
        "description": "kafka-tfrx\n==========\n\n\n[![Build Status](https://travis-ci.org/kryptoflow/kafka-tfrx.svg?branch=master)](https://travis-ci.org/kryptoflow/kafka-tfrx)\n\nSimple, idiomatic python API to interface Kafka topics with [RxPY](https://github.com/ReactiveX/RxPY)\n\n## Description\n\nThe goal of this library is mostly to enable reactive access to Kafka topics. It builds on top of Confluent Kafka's \npython [client](https://github.com/confluentinc/confluent-kafka-python), and allows building observable streams from\nany Kafka topic.\n\nThe main motivation for this library is using it with [online learning](https://en.wikipedia.org/wiki/Online_machine_learning), \nbut it is by no means limited to that. In a way, it provides a subset of the functionality that Kafka-Streams offers,\nwhich currently does not have a stable python implementation. \n\n\n## Usage\n\nSee `examples/`\n\n\n## Tests\n\nRun `tox` from top level dir\n\n## Note\n\nThis project has been set up using PyScaffold 3.0.3. For details and\nusage information on PyScaffold see <http://pyscaffold.org/>.\n",
        "description_content_type": "",
        "docs_url": null,
        "download_url": "",
        "downloads": {
            "last_day": -1,
            "last_month": -1,
            "last_week": -1
        },
        "home_page": "http://...",
        "keywords": "",
        "license": "mit",
        "maintainer": "",
        "maintainer_email": "",
        "name": "kafka-tfrx",
        "package_url": "https://pypi.org/project/kafka-tfrx/",
        "platform": "any",
        "project_url": "https://pypi.org/project/kafka-tfrx/",
        "project_urls": {
            "Homepage": "http://..."
        },
        "release_url": "https://pypi.org/project/kafka-tfrx/0.14.0/",
        "requires_dist": null,
        "requires_python": "",
        "summary": "Add a short description here!",
        "version": "0.14.0"
    },
    "last_serial": 4398173,
    "releases": {
        "0.0.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "6ff8b4b7ffcc2b793ccf6102233bb804",
                    "sha256": "29b4dd86a13ebf2ddfb5c2aab2764478a78f73865f5e05b33d25cd9863112a33"
                },
                "downloads": -1,
                "filename": "kafka_tfrx-0.0.0-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "6ff8b4b7ffcc2b793ccf6102233bb804",
                "packagetype": "bdist_wheel",
                "python_version": "3.6",
                "requires_python": null,
                "size": 6635,
                "upload_time": "2018-06-10T20:13:36",
                "url": "https://files.pythonhosted.org/packages/db/61/e87579475e5cefbd72049aa8068df0d1a390752b040ecac79e2a81f68483/kafka_tfrx-0.0.0-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "780b714dea8574e0b1d40f9fef766adf",
                    "sha256": "d228f6965152be51797bee49183a78704319271c980db6c6bcbb21f9ca4ef2d1"
                },
                "downloads": -1,
                "filename": "kafka-tfrx-0.0.0.tar.gz",
                "has_sig": false,
                "md5_digest": "780b714dea8574e0b1d40f9fef766adf",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 4577,
                "upload_time": "2018-06-10T20:13:35",
                "url": "https://files.pythonhosted.org/packages/7e/d4/5356380e6663fd958f4897d01dcb32b3b26e813a6248d3c27e4eaf2259e1/kafka-tfrx-0.0.0.tar.gz"
            }
        ],
        "0.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "88ec791f3ae99d7aacb70d4046fbaaf1",
                    "sha256": "4fcb25c534629955b7fe028e0d53c4993515961faf5388d2e62f67b782d9e1f0"
                },
                "downloads": -1,
                "filename": "kafka-tfrx-0.1.tar.gz",
                "has_sig": false,
                "md5_digest": "88ec791f3ae99d7aacb70d4046fbaaf1",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 14731,
                "upload_time": "2018-06-10T00:18:23",
                "url": "https://files.pythonhosted.org/packages/27/57/50d3ee67309fd29163909245f369fbd14f59fadefefe5a3b4e444453dc00/kafka-tfrx-0.1.tar.gz"
            }
        ],
        "0.12": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "b54cc4871f3e88079eaba1fd5da5552a",
                    "sha256": "b84694caa2cec3d0b91172e1202135f364b23310f14d2b5f409b7596f69e9a36"
                },
                "downloads": -1,
                "filename": "kafka_tfrx-0.12-py2.py3-none-any.whl",
                "has_sig": false,
                "md5_digest": "b54cc4871f3e88079eaba1fd5da5552a",
                "packagetype": "bdist_wheel",
                "python_version": "py2.py3",
                "requires_python": null,
                "size": 3983,
                "upload_time": "2018-07-13T04:22:46",
                "url": "https://files.pythonhosted.org/packages/79/08/2a722cf507cb2e6cd5130ce6ca0a1ddc7c7f199f7bb90326cc65b802b5a2/kafka_tfrx-0.12-py2.py3-none-any.whl"
            },
            {
                "comment_text": "",
                "digests": {
                    "md5": "9a3ef87612b73f5004ede63340d722d5",
                    "sha256": "03148269a1320829d6caad47911665b8dbed703cf4d1ae291c941fc77ef87e25"
                },
                "downloads": -1,
                "filename": "kafka-tfrx-0.12.tar.gz",
                "has_sig": false,
                "md5_digest": "9a3ef87612b73f5004ede63340d722d5",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 4478,
                "upload_time": "2018-06-10T20:28:44",
                "url": "https://files.pythonhosted.org/packages/6b/6f/6da92363b51ca8a3a1ee920ccb1a92a1b2c9677fc6ddde7cf50cf02447ef/kafka-tfrx-0.12.tar.gz"
            }
        ],
        "0.13.1": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "d76f80a72f899cf85fd0edb2ef4c0072",
                    "sha256": "9b69a35863222e8d4ac93ab07ca2bcad35660e4ed6d52d54228e8fa567b89ac2"
                },
                "downloads": -1,
                "filename": "kafka-tfrx-0.13.1.tar.gz",
                "has_sig": false,
                "md5_digest": "d76f80a72f899cf85fd0edb2ef4c0072",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 14408,
                "upload_time": "2018-07-13T04:51:46",
                "url": "https://files.pythonhosted.org/packages/13/ac/365687e5afb6fbf0cccb7de0e45475ae1a5d7956f789683db3bd7e28f1c2/kafka-tfrx-0.13.1.tar.gz"
            }
        ],
        "0.14.0": [
            {
                "comment_text": "",
                "digests": {
                    "md5": "1cc4be3922ff1a6e8c62ab4bcd9e0b07",
                    "sha256": "d7fc8a98fb563fa29877fc28060830294dc8653e0df368e673ee0ed041ab7401"
                },
                "downloads": -1,
                "filename": "kafka-tfrx-0.14.0.tar.gz",
                "has_sig": false,
                "md5_digest": "1cc4be3922ff1a6e8c62ab4bcd9e0b07",
                "packagetype": "sdist",
                "python_version": "source",
                "requires_python": null,
                "size": 14518,
                "upload_time": "2018-10-20T22:34:14",
                "url": "https://files.pythonhosted.org/packages/c4/56/96404ab8ef77aee458715ff13378aaa2d3dd9e1ae2be5cf2288bdb26dadc/kafka-tfrx-0.14.0.tar.gz"
            }
        ]
    },
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "1cc4be3922ff1a6e8c62ab4bcd9e0b07",
                "sha256": "d7fc8a98fb563fa29877fc28060830294dc8653e0df368e673ee0ed041ab7401"
            },
            "downloads": -1,
            "filename": "kafka-tfrx-0.14.0.tar.gz",
            "has_sig": false,
            "md5_digest": "1cc4be3922ff1a6e8c62ab4bcd9e0b07",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": null,
            "size": 14518,
            "upload_time": "2018-10-20T22:34:14",
            "url": "https://files.pythonhosted.org/packages/c4/56/96404ab8ef77aee458715ff13378aaa2d3dd9e1ae2be5cf2288bdb26dadc/kafka-tfrx-0.14.0.tar.gz"
        }
    ]
}