{ "info": { "author": "IBM Streams @ github.com", "author_email": "rolef.heinrich@de.ibm.com", "bugtrack_url": null, "classifiers": [ "Development Status :: 5 - Production/Stable", "License :: OSI Approved :: Apache Software License", "Programming Language :: Python :: 3", "Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6", "Programming Language :: Python :: 3.7" ], "description": "Overview\n========\n\nProvides functions to read messages from a Kafka broker as a stream\nand submit tuples to a Kafka broker as messages.\n\nThe broker configuration must be done with properties in an application configuration or by\nusing a dictionary variable.\nThe minimum set of properties must contain the `bootstrap.servers` configuration, which is valid\nfor both consumers and producers, i.e. for the `subscribe` and `publish` functions.\n\nIt is also possible to use different application configurations for subscribe and publish\nwhen special consumer or producer configs must be used.\n\nSample\n======\n\nA simple hello world example of a Streams application publishing to\na topic and the same application consuming the same topic::\n\n from streamsx.topology.topology import Topology\n from streamsx.topology.schema import CommonSchema\n from streamsx.topology.context import submit, ContextTypes\n import streamsx.kafka as kafka\n import time\n\n def delay(v):\n time.sleep(5.0)\n return True\n\n topology = Topology('KafkaHelloWorld')\n\n to_kafka = topology.source(['Hello', 'World!'])\n to_kafka = to_kafka.as_string()\n # delay tuple by tuple\n to_kafka = to_kafka.filter(delay)\n\n # Publish a stream to Kafka using TEST topic, the Kafka servers\n # assuming, the broker is running on localhost, port 9092\n kafka_props = {}\n kafka_props['bootstrap.servers'] = 'localhost:9092'\n kafka.publish(to_kafka, 'TEST', kafka_props)\n\n # Subscribe to same topic as a stream\n from_kafka = kafka.subscribe(topology, 'TEST', kafka_props, CommonSchema.String)\n\n # You'll find the Hello World! in stdout log file:\n from_kafka.print()\n\n submit(ContextTypes.DISTRIBUTED, topology)\n # The Streams job is kept running.\n\nDocumentation\n=============\n\n* `streamsx.kafka package documentation `_\n", "description_content_type": "", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://github.com/IBMStreams/pypi.streamsx.kafka", "keywords": "streams", "license": "Apache License - Version 2.0", "maintainer": "", "maintainer_email": "", "name": "streamsx.kafka", "package_url": "https://pypi.org/project/streamsx.kafka/", "platform": "", "project_url": "https://pypi.org/project/streamsx.kafka/", "project_urls": { "Homepage": "https://github.com/IBMStreams/pypi.streamsx.kafka" }, "release_url": "https://pypi.org/project/streamsx.kafka/1.6.1/", "requires_dist": null, "requires_python": "", "summary": "IBM Streams Kafka integration", "version": "1.6.1" }, "last_serial": 5861751, "releases": { "0.1.0": [ { "comment_text": "", "digests": { "md5": "706833472d23b0abaca06971d99951fc", "sha256": "86a16739d69a3dc337e1c1f7ac4baba7937fd29a20f7843dd6a91f35c5c1d74d" }, "downloads": -1, "filename": "streamsx.kafka-0.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "706833472d23b0abaca06971d99951fc", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 9197, "upload_time": "2019-01-14T13:33:12", "url": "https://files.pythonhosted.org/packages/d6/26/63fd8124840b1c870c36c41ed5602cab8e4e88a908df2b1c13792f253a7a/streamsx.kafka-0.1.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "5888c68daaf0b6acf3f82391d921826c", "sha256": "dee0075e11022710af1b0418a18c579044ab3015cf9908003c342d290e7c11aa" }, "downloads": -1, "filename": "streamsx.kafka-0.1.0.tar.gz", "has_sig": false, "md5_digest": "5888c68daaf0b6acf3f82391d921826c", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4097, "upload_time": "2019-01-14T13:33:09", "url": "https://files.pythonhosted.org/packages/06/04/25501941410bd04b7dc63db38599cee0883cd15264cd42aa360a96ba9eb2/streamsx.kafka-0.1.0.tar.gz" } ], "0.1.1": [ { "comment_text": "", "digests": { "md5": "f716e8dcc6d704585d00ee1fa352aa55", "sha256": "9a595604fa9366012e994eb1f69e1405630c718435602889b709a4903a18b92c" }, "downloads": -1, "filename": "streamsx.kafka-0.1.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "f716e8dcc6d704585d00ee1fa352aa55", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 9197, "upload_time": "2019-01-14T13:47:34", "url": "https://files.pythonhosted.org/packages/2a/a6/5a6ef5921091813994a1530990761625755839fb8eb0a9cd999014755683/streamsx.kafka-0.1.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "593c389d940becd4666f12e65eeec9da", "sha256": "532febc9716964d0b0fd27ec36422186757465c006feb32d8ffb375d9f506837" }, "downloads": -1, "filename": "streamsx.kafka-0.1.1.tar.gz", "has_sig": false, "md5_digest": "593c389d940becd4666f12e65eeec9da", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4095, "upload_time": "2019-01-14T13:47:32", "url": "https://files.pythonhosted.org/packages/b3/30/7e4634c04c99938af0208848447f4ae2a624c7c6a5ac3acb0c4869e7612f/streamsx.kafka-0.1.1.tar.gz" } ], "1.0.1": [ { "comment_text": "", "digests": { "md5": "5e0a801ea13c60854ebb47fa900210e9", "sha256": "67c2c4880f10c5cc90dd8683d19885645c6b0778090dcbeafaa440a587de61f6" }, "downloads": -1, "filename": "streamsx.kafka-1.0.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "5e0a801ea13c60854ebb47fa900210e9", "packagetype": "bdist_wheel", "python_version": "3.5", "requires_python": null, "size": 9625, "upload_time": "2019-02-05T12:48:43", "url": "https://files.pythonhosted.org/packages/8c/4d/6da9d1cee9f4bb3857112ec76a93f0d09657f9973f8ad66c6a17b88f28cb/streamsx.kafka-1.0.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "5ab67c8f6346697d4d8706038ea1fabd", "sha256": "f9d3ca47b8b0788d92ca5b10262f295d0d9989ff1afd5ee7086cc9cb8a4efd1b" }, "downloads": -1, "filename": "streamsx.kafka-1.0.1.tar.gz", "has_sig": false, "md5_digest": "5ab67c8f6346697d4d8706038ea1fabd", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 4488, "upload_time": "2019-02-05T12:48:41", "url": "https://files.pythonhosted.org/packages/fb/41/6cc9df4c8c07523219682369112143dc4938ad23a40586d9a02ccc874c52/streamsx.kafka-1.0.1.tar.gz" } ], "1.1.0": [ { "comment_text": "", "digests": { "md5": "85c25cf768640ef8e52f1f4b677b2067", "sha256": "dff6dfda22df3f261940e5f9e0425e2a4cd25dbf506dafb6f6043825fed632d0" }, "downloads": -1, "filename": "streamsx.kafka-1.1.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "85c25cf768640ef8e52f1f4b677b2067", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 10495, "upload_time": "2019-05-09T06:59:22", "url": "https://files.pythonhosted.org/packages/88/53/2080bf56fc5e794790c5428d04996def24ce34afdf8a124ef9ced3e49d56/streamsx.kafka-1.1.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "1e3595e2c234f5cbd4437cb4cf3291bf", "sha256": "618e6bf71b3df68a7e4e42b3ed5ddf6dd54fab9544494398c3c2e3c095005d8f" }, "downloads": -1, "filename": "streamsx.kafka-1.1.0.tar.gz", "has_sig": false, "md5_digest": "1e3595e2c234f5cbd4437cb4cf3291bf", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 9301, "upload_time": "2019-05-09T06:59:20", "url": "https://files.pythonhosted.org/packages/ed/3b/1987fed089714af9a2b3e46b3d86e01743835b94920e0d44594a2b12b4ca/streamsx.kafka-1.1.0.tar.gz" } ], "1.2.0": [ { "comment_text": "", "digests": { "md5": "882951fb0e9220ab97882b77f41bf1e4", "sha256": "9e85d86c185403d117fc29194e16c67495dba4d994de6c88ec4c5a0e52c0e8d1" }, "downloads": -1, "filename": "streamsx.kafka-1.2.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "882951fb0e9220ab97882b77f41bf1e4", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 13793, "upload_time": "2019-05-22T07:34:29", "url": "https://files.pythonhosted.org/packages/a5/ae/fbd64d4d364ef674abf2ec2ce6912400dbb6ed5ccd156fd9f1452a352ac6/streamsx.kafka-1.2.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "74bea76b67e7dedd5c0524dd73ef3435", "sha256": "173d50c5cadcc99eb79933a4bad173c7178967730bf7c25985e4800ca95083ac" }, "downloads": -1, "filename": "streamsx.kafka-1.2.0.tar.gz", "has_sig": false, "md5_digest": "74bea76b67e7dedd5c0524dd73ef3435", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 12011, "upload_time": "2019-05-22T07:34:26", "url": "https://files.pythonhosted.org/packages/02/0d/437ae3a72ae20d0643511fd25bd82edc05b96d81ff9f179fd3cd8091e852/streamsx.kafka-1.2.0.tar.gz" } ], "1.2.1": [ { "comment_text": "", "digests": { "md5": "2cc2422329697d703d02c215184e02e5", "sha256": "c02bbbb42a7683119cc1a79128a0d8ae69a1a81b57bdac13e172f8f52d129bec" }, "downloads": -1, "filename": "streamsx.kafka-1.2.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "2cc2422329697d703d02c215184e02e5", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 13864, "upload_time": "2019-05-24T07:06:09", "url": "https://files.pythonhosted.org/packages/96/7d/17d312f89f8a89f432593c8bf51c0d7ef1308d8fd091901c64e0d8291e2d/streamsx.kafka-1.2.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "d63913530286c46322b42163823f0448", "sha256": "f5b24873366589fd9658b8a51d9cdf950fbc3620c65e779e1a22d7c6b7701a3b" }, "downloads": -1, "filename": "streamsx.kafka-1.2.1.tar.gz", "has_sig": false, "md5_digest": "d63913530286c46322b42163823f0448", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 12103, "upload_time": "2019-05-24T07:06:06", "url": "https://files.pythonhosted.org/packages/59/ff/3b3b798f6d3fe83e97eed04390b91a0b17ce0c9b4d5da75cb2f2fa2b1f72/streamsx.kafka-1.2.1.tar.gz" } ], "1.2.2": [ { "comment_text": "", "digests": { "md5": "032da7567652435eb7a4597ea3403a83", "sha256": "7c04e2c11eacf29da71ab59a7483943480268e1c8e8dad65f2d312fd88978dcf" }, "downloads": -1, "filename": "streamsx.kafka-1.2.2-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "032da7567652435eb7a4597ea3403a83", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 13933, "upload_time": "2019-06-03T11:33:31", "url": "https://files.pythonhosted.org/packages/ac/61/2df0ba2089e0286cfab43a47cbb4b11b33ec8587428e8371a986aa546915/streamsx.kafka-1.2.2-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "f24ccbd85a2c3cd9b4b039d2e74cda73", "sha256": "1fbdab3b0a1f6215c506c4ad335323c1e308b993f4737d664eb2d40f6c9befc6" }, "downloads": -1, "filename": "streamsx.kafka-1.2.2.tar.gz", "has_sig": false, "md5_digest": "f24ccbd85a2c3cd9b4b039d2e74cda73", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 12147, "upload_time": "2019-06-03T11:33:29", "url": "https://files.pythonhosted.org/packages/88/27/10dbaae9369c23576e1421caf1869b7a9cd67c81e7ed738d1fced9f86c71/streamsx.kafka-1.2.2.tar.gz" } ], "1.2.4": [ { "comment_text": "", "digests": { "md5": "fd1c28ff67840cbe6ed83c8d48a07740", "sha256": "9bbbdce9ca776adf0b6c00f98fc8bcbf52166ff6201a49bce0807dd9410642d7" }, "downloads": -1, "filename": "streamsx.kafka-1.2.4-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "fd1c28ff67840cbe6ed83c8d48a07740", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 13930, "upload_time": "2019-06-11T09:47:36", "url": "https://files.pythonhosted.org/packages/eb/0d/5e84a0b5f00653bdcb74a7e257cf116adb861c625a4b12d70c4bcbae0396/streamsx.kafka-1.2.4-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "23ddfd8f81f3b2ebcf0677bc2970d7cc", "sha256": "13220f9af4c68a5bdee595d405af9992b1697d0944aee5c6a580f4e0495d51f3" }, "downloads": -1, "filename": "streamsx.kafka-1.2.4.tar.gz", "has_sig": false, "md5_digest": "23ddfd8f81f3b2ebcf0677bc2970d7cc", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 12145, "upload_time": "2019-06-11T09:47:34", "url": "https://files.pythonhosted.org/packages/f0/35/86c9478c132c4ffd20ab9ca8135d327f1ad01a9e247ae3adf3715849d2de/streamsx.kafka-1.2.4.tar.gz" } ], "1.3.0": [ { "comment_text": "", "digests": { "md5": "8c4568b760ed4206f8ead25599732320", "sha256": "48669f390807024f19b39ad17c25a2303055bdb4be68bacc49e5af420c263dfa" }, "downloads": -1, "filename": "streamsx.kafka-1.3.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "8c4568b760ed4206f8ead25599732320", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 20409, "upload_time": "2019-08-29T08:28:26", "url": "https://files.pythonhosted.org/packages/2b/18/fe103516b0b1771f721b3d20b86bf8ac337f89055c2bf7c2162df7012ad4/streamsx.kafka-1.3.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "4bd719cb1b7ab9320b8107efaeb61c89", "sha256": "87656a070aa4685c09b21ce5b04824dfb7b699df22d438abc860712d69b03c37" }, "downloads": -1, "filename": "streamsx.kafka-1.3.0.tar.gz", "has_sig": false, "md5_digest": "4bd719cb1b7ab9320b8107efaeb61c89", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 18575, "upload_time": "2019-08-29T08:28:24", "url": "https://files.pythonhosted.org/packages/63/99/995293c46d6f137ef7a4b81356e60d63c92e70102cde63d70c9f0359ba1c/streamsx.kafka-1.3.0.tar.gz" } ], "1.4.0": [ { "comment_text": "", "digests": { "md5": "22727be384b4aacc4d1d8c72ef101d26", "sha256": "efe191f7e27fd4cb5f7211abd1921329d633b1b298282599c2af388bfa1dcfd6" }, "downloads": -1, "filename": "streamsx.kafka-1.4.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "22727be384b4aacc4d1d8c72ef101d26", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 19956, "upload_time": "2019-09-02T14:01:44", "url": "https://files.pythonhosted.org/packages/ec/a5/6f791afe17da8f614ed155f8cea420a285f7fcbb5554e8b6612ac31fa75a/streamsx.kafka-1.4.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "0a082cb58b398f9796feba01acab3f45", "sha256": "f2a50f0a60ce483e78e924aa9f652d6ba32619d688473d2168adf565b34f55f1" }, "downloads": -1, "filename": "streamsx.kafka-1.4.0.tar.gz", "has_sig": false, "md5_digest": "0a082cb58b398f9796feba01acab3f45", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 18127, "upload_time": "2019-09-02T14:01:41", "url": "https://files.pythonhosted.org/packages/01/f9/e7d7b8e524b53d2e48fba1af6fe085b4da1cfc5fa6cff4225c9dd0cce738/streamsx.kafka-1.4.0.tar.gz" } ], "1.4.1": [ { "comment_text": "", "digests": { "md5": "94a706303f93ffe31b2a971894135b2a", "sha256": "c9bd1a33e47155555a41d721de3fc71c1402d5979f6cf504047c59dc59ffc63b" }, "downloads": -1, "filename": "streamsx.kafka-1.4.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "94a706303f93ffe31b2a971894135b2a", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 20095, "upload_time": "2019-09-04T12:33:29", "url": "https://files.pythonhosted.org/packages/7a/fd/1962364a7cf71b278624c67d588d334f89f779d900118f4e08e2b5bcceaf/streamsx.kafka-1.4.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "8c42cef3cb733aba2a8f88733af09bb8", "sha256": "eb1759681b895f25c7fbd7c95c6c119c0aae9a8da81309a262709ae1883edae2" }, "downloads": -1, "filename": "streamsx.kafka-1.4.1.tar.gz", "has_sig": false, "md5_digest": "8c42cef3cb733aba2a8f88733af09bb8", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 18228, "upload_time": "2019-09-04T12:33:27", "url": "https://files.pythonhosted.org/packages/44/59/68b66543ba933e16715037ce84f2744777a98784829408d1c3437c192e1b/streamsx.kafka-1.4.1.tar.gz" } ], "1.5.0": [ { "comment_text": "", "digests": { "md5": "cc9b4e0543fbb5c0df2ba0d215a749e0", "sha256": "76a3f1ae93f60e6f0be34853fe1635d7d388afc5a16a73060d4cc3c63dc5e38e" }, "downloads": -1, "filename": "streamsx.kafka-1.5.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "cc9b4e0543fbb5c0df2ba0d215a749e0", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 20515, "upload_time": "2019-09-05T09:36:43", "url": "https://files.pythonhosted.org/packages/9a/a1/1131ae33f61285e53e5515e83aacdaf7620f627208a10c37527108993ddd/streamsx.kafka-1.5.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "61ea9ffc641af2a649e7f2df04808252", "sha256": "b7b6c556b8c7fd2e1857219dfdd9302276711ce2b17ba48ab7e88e7cb077aaf3" }, "downloads": -1, "filename": "streamsx.kafka-1.5.0.tar.gz", "has_sig": false, "md5_digest": "61ea9ffc641af2a649e7f2df04808252", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 18641, "upload_time": "2019-09-05T09:36:41", "url": "https://files.pythonhosted.org/packages/58/fb/28d6ed9d40a078a9caa481d2d05e0c481e99b4777158c020ea8ed540dcaa/streamsx.kafka-1.5.0.tar.gz" } ], "1.6.0": [ { "comment_text": "", "digests": { "md5": "8ba950cc2a5743f0c6835b1139ffdcfc", "sha256": "e7f82c6866fcb4c5989ad93aa01aefab539b570df938a3cc7e680cbd0633d458" }, "downloads": -1, "filename": "streamsx.kafka-1.6.0-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "8ba950cc2a5743f0c6835b1139ffdcfc", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 24027, "upload_time": "2019-09-09T08:39:38", "url": "https://files.pythonhosted.org/packages/92/2f/48ae754fca60eb0eacbfc77326eba2e1785a98259f65ec7c4c6a094d312b/streamsx.kafka-1.6.0-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "6bac6eb5e1b5a9ada3a3e16fad015508", "sha256": "ac4701687c0d6d0d18b6c444e30d0db7e8122bdc1f5f133cb7bd9cc42621fe1e" }, "downloads": -1, "filename": "streamsx.kafka-1.6.0.tar.gz", "has_sig": false, "md5_digest": "6bac6eb5e1b5a9ada3a3e16fad015508", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 21251, "upload_time": "2019-09-09T08:39:35", "url": "https://files.pythonhosted.org/packages/b6/88/b646479f9ddf8e275262768ff0dbaaf4be11ecd6f44942594a7f6d19f48c/streamsx.kafka-1.6.0.tar.gz" } ], "1.6.1": [ { "comment_text": "", "digests": { "md5": "a1eb2ae9808dbf2633fde4956bb3ac52", "sha256": "c6627ff93d69878c515ee3fbe86298012cb8562ad856da76bd575dc6a266c650" }, "downloads": -1, "filename": "streamsx.kafka-1.6.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "a1eb2ae9808dbf2633fde4956bb3ac52", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 24109, "upload_time": "2019-09-20T11:10:28", "url": "https://files.pythonhosted.org/packages/9e/9d/83c9865aa4a6ea3fd96d48d9d68740b0935750452d8e4232ff230773b9c5/streamsx.kafka-1.6.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "970a5f49852f0ca0cde9adca681a1a39", "sha256": "342a3ede5e94696b656d0a23c8ac1de5ca116fdac8543dd6d434ed051d10da08" }, "downloads": -1, "filename": "streamsx.kafka-1.6.1.tar.gz", "has_sig": false, "md5_digest": "970a5f49852f0ca0cde9adca681a1a39", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 21336, "upload_time": "2019-09-20T11:10:25", "url": "https://files.pythonhosted.org/packages/5d/00/a6479f5910260d9e8743d807176ebf32141f418536a30bdedee748096737/streamsx.kafka-1.6.1.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "a1eb2ae9808dbf2633fde4956bb3ac52", "sha256": "c6627ff93d69878c515ee3fbe86298012cb8562ad856da76bd575dc6a266c650" }, "downloads": -1, "filename": "streamsx.kafka-1.6.1-py2.py3-none-any.whl", "has_sig": false, "md5_digest": "a1eb2ae9808dbf2633fde4956bb3ac52", "packagetype": "bdist_wheel", "python_version": "3.6", "requires_python": null, "size": 24109, "upload_time": "2019-09-20T11:10:28", "url": "https://files.pythonhosted.org/packages/9e/9d/83c9865aa4a6ea3fd96d48d9d68740b0935750452d8e4232ff230773b9c5/streamsx.kafka-1.6.1-py2.py3-none-any.whl" }, { "comment_text": "", "digests": { "md5": "970a5f49852f0ca0cde9adca681a1a39", "sha256": "342a3ede5e94696b656d0a23c8ac1de5ca116fdac8543dd6d434ed051d10da08" }, "downloads": -1, "filename": "streamsx.kafka-1.6.1.tar.gz", "has_sig": false, "md5_digest": "970a5f49852f0ca0cde9adca681a1a39", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 21336, "upload_time": "2019-09-20T11:10:25", "url": "https://files.pythonhosted.org/packages/5d/00/a6479f5910260d9e8743d807176ebf32141f418536a30bdedee748096737/streamsx.kafka-1.6.1.tar.gz" } ] }