{
"info": {
"author": "Dana Powers",
"author_email": "dana.powers@gmail.com",
"bugtrack_url": null,
"classifiers": [
"Development Status :: 4 - Beta",
"Intended Audience :: Developers",
"License :: OSI Approved :: Apache Software License",
"Programming Language :: Python",
"Programming Language :: Python :: 2",
"Programming Language :: Python :: 2.6",
"Programming Language :: Python :: 2.7",
"Programming Language :: Python :: 3",
"Programming Language :: Python :: 3.3",
"Programming Language :: Python :: 3.4",
"Programming Language :: Python :: 3.5",
"Programming Language :: Python :: Implementation :: PyPy",
"Topic :: Software Development :: Libraries :: Python Modules"
],
"description": "Kafka Python client\n------------------------\n\n.. image:: https://img.shields.io/badge/kafka-0.9%2C%200.8.2%2C%200.8.1%2C%200.8-brightgreen.svg\n :target: https://kafka-python.readthedocs.org/compatibility.html\n.. image:: https://img.shields.io/pypi/pyversions/kafka-python.svg\n :target: https://pypi.python.org/pypi/kafka-python\n.. image:: https://coveralls.io/repos/dpkp/kafka-python/badge.svg?branch=master&service=github\n :target: https://coveralls.io/github/dpkp/kafka-python?branch=master\n.. image:: https://travis-ci.org/dpkp/kafka-python.svg?branch=master\n :target: https://travis-ci.org/dpkp/kafka-python\n.. image:: https://img.shields.io/badge/license-Apache%202-blue.svg\n :target: https://github.com/dpkp/kafka-python/blob/master/LICENSE\n\n>>> pip install kafka-python\n\nkafka-python is a client for the Apache Kafka distributed stream processing\nsystem. It is designed to function much like the official java client, with a\nsprinkling of pythonic interfaces (e.g., iterators).\n\n\nKafkaConsumer\n*************\n\n>>> from kafka import KafkaConsumer\n>>> consumer = KafkaConsumer('my_favorite_topic')\n>>> for msg in consumer:\n... print (msg)\n\nKafkaConsumer is a full-featured,\nhigh-level message consumer class that is similar in design and function to the\nnew 0.9 java consumer. Most configuration parameters defined by the official\njava client are supported as optional kwargs, with generally similar behavior.\nGzip and Snappy compressed messages are supported transparently.\n\nIn addition to the standard KafkaConsumer.poll() interface (which returns\nmicro-batches of messages, grouped by topic-partition), kafka-python supports\nsingle-message iteration, yielding ConsumerRecord namedtuples, which include\nthe topic, partition, offset, key, and value of each message.\n\nBy default, KafkaConsumer will attempt to auto-commit\nmessage offsets every 5 seconds. When used with 0.9 kafka brokers,\nKafkaConsumer will dynamically assign partitions using\nthe kafka GroupCoordinator APIs and a RoundRobinPartitionAssignor\npartitioning strategy, enabling relatively straightforward parallel consumption\npatterns. See `ReadTheDocs `_\nfor examples.\n\n\nKafkaProducer\n*************\n\n<`in progress - see SimpleProducer for legacy producer implementation`>\n\n\nProtocol\n********\n\nA secondary goal of kafka-python is to provide an easy-to-use protocol layer\nfor interacting with kafka brokers via the python repl. This is useful for\ntesting, probing, and general experimentation. The protocol support is\nleveraged to enable a KafkaClient.check_version() method that\nprobes a kafka broker and attempts to identify which version it is running\n(0.8.0 to 0.9).\n\n\nLow-level\n*********\n\nLegacy support is maintained for low-level consumer and producer classes,\nSimpleConsumer and SimpleProducer. See\n`ReadTheDocs `_ for API details.",
"description_content_type": null,
"docs_url": null,
"download_url": "UNKNOWN",
"downloads": {
"last_day": -1,
"last_month": -1,
"last_week": -1
},
"home_page": "https://github.com/dpkp/kafka-python",
"keywords": "apache kafka",
"license": "Apache License 2.0",
"maintainer": null,
"maintainer_email": null,
"name": "gc-kafka-python",
"package_url": "https://pypi.org/project/gc-kafka-python/",
"platform": "UNKNOWN",
"project_url": "https://pypi.org/project/gc-kafka-python/",
"project_urls": {
"Download": "UNKNOWN",
"Homepage": "https://github.com/dpkp/kafka-python"
},
"release_url": "https://pypi.org/project/gc-kafka-python/0.9.8/",
"requires_dist": null,
"requires_python": null,
"summary": "Pure Python client for Apache Kafka",
"version": "0.9.8"
},
"last_serial": 1899517,
"releases": {
"0.9.5": [
{
"comment_text": "",
"digests": {
"md5": "0c7e3d9918ea32a130d61129cc3ce014",
"sha256": "12bd079c74ac3b18d8f307a61d2141cf66a78476f696ca6c236c4646c5fb13fb"
},
"downloads": -1,
"filename": "gc-kafka-python-0.9.5.tar.gz",
"has_sig": false,
"md5_digest": "0c7e3d9918ea32a130d61129cc3ce014",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 63211,
"upload_time": "2015-10-09T13:37:29",
"url": "https://files.pythonhosted.org/packages/df/93/2bfd29d7dc7ceac91e84cc10d93b4627d36f3e08642caef1adfd976f7711/gc-kafka-python-0.9.5.tar.gz"
}
],
"0.9.6": [],
"0.9.7": [
{
"comment_text": "",
"digests": {
"md5": "19c948eca0024db6e739535216a39034",
"sha256": "f8a3d6cdcfa25813d1f8425e721dfcf24a2b12440202c0d09c575897e76ece15"
},
"downloads": -1,
"filename": "gc-kafka-python-0.9.7.tar.gz",
"has_sig": false,
"md5_digest": "19c948eca0024db6e739535216a39034",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 123357,
"upload_time": "2016-01-11T17:05:35",
"url": "https://files.pythonhosted.org/packages/15/6d/2e70ac14e3344db75a6dbfae4818a9ec7b8f211755a193305242ec6f83d5/gc-kafka-python-0.9.7.tar.gz"
}
],
"0.9.8": [
{
"comment_text": "",
"digests": {
"md5": "9a760084b2d276bc1fc4614372becf41",
"sha256": "b68bdf0952e4baea534442c36a334ad75fcb31c209c79a3947cb61867a898eec"
},
"downloads": -1,
"filename": "gc-kafka-python-0.9.8.tar.gz",
"has_sig": false,
"md5_digest": "9a760084b2d276bc1fc4614372becf41",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 123361,
"upload_time": "2016-01-11T18:27:41",
"url": "https://files.pythonhosted.org/packages/06/0e/accfc40501b35d0bcfe6d5c82cd23f2443099727fb2d2d2e9fdfbe2ebd3a/gc-kafka-python-0.9.8.tar.gz"
}
]
},
"urls": [
{
"comment_text": "",
"digests": {
"md5": "9a760084b2d276bc1fc4614372becf41",
"sha256": "b68bdf0952e4baea534442c36a334ad75fcb31c209c79a3947cb61867a898eec"
},
"downloads": -1,
"filename": "gc-kafka-python-0.9.8.tar.gz",
"has_sig": false,
"md5_digest": "9a760084b2d276bc1fc4614372becf41",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 123361,
"upload_time": "2016-01-11T18:27:41",
"url": "https://files.pythonhosted.org/packages/06/0e/accfc40501b35d0bcfe6d5c82cd23f2443099727fb2d2d2e9fdfbe2ebd3a/gc-kafka-python-0.9.8.tar.gz"
}
]
}