kafka

View on PyPIReverse Dependencies (23)

1.3.5 kafka-1.3.5-py2.py3-none-any.whl

Wheel Details

Project: kafka
Version: 1.3.5
Filename: kafka-1.3.5-py2.py3-none-any.whl
Download: [link]
Size: 207188
MD5: 202922991a486f6057a8867143ab3909
SHA256: 35a49e9a432f6792aad48b2ab09d03867357aaa06eacba2678b7fd0808156e5c
Uploaded: 2017-10-07 23:53:13 +0000

dist-info

METADATA

Metadata-Version: 2.0
Name: kafka
Version: 1.3.5
Summary: Pure Python client for Apache Kafka
Author: Dana Powers
Author-Email: dana.powers[at]gmail.com
Home-Page: https://github.com/dpkp/kafka-python
License: Apache License 2.0
Keywords: apache kafka
Classifier: Development Status :: 5 - Production/Stable
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 2
Classifier: Programming Language :: Python :: 2.7
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.4
Classifier: Programming Language :: Python :: 3.5
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: Implementation :: PyPy
Classifier: Topic :: Software Development :: Libraries :: Python Modules
[Description omitted; length: 6037 characters]

WHEEL

Wheel-Version: 1.0
Generator: bdist_wheel (0.29.0)
Root-Is-Purelib: true
Tag: py2-none-any
Tag: py3-none-any

RECORD

Path Digest Size
kafka/__init__.py sha256=ct9hVstrrIwQ5OLK0CfFETHX-4vBcOwDoSQhI5kl85M 1961
kafka/client.py sha256=UpWmCWyD8de5RT_iF0McniVLb9zJAdCubM6sgCEYGWA 28941
kafka/client_async.py sha256=hHZ4QuDs3547oFywjL1-7fGTE9y-Jl__BIzRD9XQwdM 42864
kafka/cluster.py sha256=4U6BfI77EEjwsiiXlUWac7OtoxFduMDlImy0iaDB6d0 13351
kafka/codec.py sha256=i319PZbiG0SROtq4A8JmQTlThTlhX9cQBSX4H10TZrE 8244
kafka/common.py sha256=crlRAwWfDxorxH5a4Nu1iflNTdKcrtjmtSCvnTOvtRs 95
kafka/conn.py sha256=hPn6PLVjlNxuFvzYXjLV-uWC5FSrg43EWOHqjg8cqmI 55457
kafka/context.py sha256=tA8XjtnZl-vGR2eIR-3eFdwqcahdxSuGM_1VZIjK7kM 5995
kafka/errors.py sha256=Oly1M7sIy2_RIPeKovdJ1kZS6A_DDU_lFOuF2npp31Q 15088
kafka/future.py sha256=uJJLfKMFsdEHgHSyvCzQe_AXNrToiZE-MynZVNhk9qc 2474
kafka/structs.py sha256=90pu46WW67zYKrAv9eByurJ67T4G3rbhhY4qUpBmVJo 3534
kafka/util.py sha256=uiFyVpeIOsy6fHE73POxOFf-oyCCUxCOQO_rX6uolOo 5037
kafka/version.py sha256=AraH1WB67qbGfdcq6TC7ARcEi7zORceoTxsCTwF_h8g 22
kafka/consumer/__init__.py sha256=otImmtxGat2D_QRLy08bGcOLE7HBeG7rcwnbhiPkWug 232
kafka/consumer/base.py sha256=SjpB0X8bzt4u45cDlCnFH7IwaiVoS7jjh9INDIIkq2M 7726
kafka/consumer/fetcher.py sha256=QtlVCbZqFemeJK2cFpIvF8zSzFsTKmjOU88TIt8Xx4U 48603
kafka/consumer/group.py sha256=A4c-LFfN6P40YJmVuTDrevq0BTQU68Z3XSh6OpZ7uJI 51975
kafka/consumer/multiprocess.py sha256=OxrAbsc9qQkRFyXcAqGqfNHfgEG0ZQmNpjrQFo5ZBw8 11744
kafka/consumer/simple.py sha256=7B0sfI4PRHKsrPQh6bKFQ7j6RmS5XZZEnCT0NCuysK8 18643
kafka/consumer/subscription_state.py sha256=KTKejMaELsBSxm_uajIuEv1pGFWEsvwaDXlHFrlKQzo 21380
kafka/coordinator/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka/coordinator/base.py sha256=O3MzICuNQYlBrMPiBAwmQDmp_xBNSSBvmow82BAYG8o 32927
kafka/coordinator/consumer.py sha256=C1LU0Sw8g931tKbWyaJUoKe0005GC5CYs2AauJyjRrY 33394
kafka/coordinator/heartbeat.py sha256=lAclCkKgMoZ5954FocIK88o5FLf45c7WE9Web4XkPbM 1419
kafka/coordinator/protocol.py sha256=wTaIOnUVbj0CKXZ82FktZo-zMRvOCk3hdQAoHJ62e3I 1041
kafka/coordinator/assignors/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka/coordinator/assignors/abstract.py sha256=belUnCkuw70HJ8HTWYIgVrT6pJmIBBrTl1vkO-bN1C0 1507
kafka/coordinator/assignors/range.py sha256=neyiRepTNOi_QfTQZZZewZXp6qNaVC37jKF1C2m_gLE 2967
kafka/coordinator/assignors/roundrobin.py sha256=wmMCbZtoXvmtdLh6ddbRseHiU7nyOuEQQVNOAymZI8I 3729
kafka/metrics/__init__.py sha256=BEbwrXghiTKKH0RdeDl05c4xLcqU_DB7cQEg2Z_jXlo 470
kafka/metrics/compound_stat.py sha256=CNnP71sNnViUhCDFHimdlXBb8G-PXrbqg6FfSS-SkVc 776
kafka/metrics/dict_reporter.py sha256=OvZ6SUFp-Yk3tNaWbC0ul0WXncp42ymg8bHw3O6MITA 2567
kafka/metrics/kafka_metric.py sha256=fnkHEmooLjCHRoAtti6rOymQLLMN1D276ma1bYAFJDY 933
kafka/metrics/measurable.py sha256=g5mp1c9816SRgJdgHXklTNqDoDnbeYp-opjoV3DOr7Q 770
kafka/metrics/measurable_stat.py sha256=NcOQfOieQV8m6mMClDFJDY1ibE-RmIPrth15W5XPDdU 503
kafka/metrics/metric_config.py sha256=SsibZd09icYgqLrMhXXW-pQVICPn0yYADrD8txdIMw0 1154
kafka/metrics/metric_name.py sha256=jLHfEYPDqKInE4ora6nx7jJsMq1h4sbTo50VHDhq6Es 3417
kafka/metrics/metrics.py sha256=x-7FpkTqxTK0Rx3zGMMQP43OW-bOUC_gzZRPRQbi314 10280
kafka/metrics/metrics_reporter.py sha256=2qZRLiyOUzB-2ULBtOhXOtjU9phElIlundjPluYYXgE 1398
kafka/metrics/quota.py sha256=34psI-neVNQ-VeaD2KMvpx5bBIJp4rJcsJ6rvC91Wgk 1128
kafka/metrics/stat.py sha256=T_YGImowGnUnGgeNZ-r4buk1PdM_7NHG15PzTHieyZo 628
kafka/metrics/stats/__init__.py sha256=w4eQHC6iqozFug6i9hpEqhHtagOInhekCsoUr1aV334 439
kafka/metrics/stats/avg.py sha256=WdyAFz37aQhvzIqkvbP4SGUDz9gZ-eua_Urhygjc2xU 678
kafka/metrics/stats/count.py sha256=dy5sdPVLOwsiVcfOawEx7EOyjSTXxUKqsJl84sjVZbQ 487
kafka/metrics/stats/histogram.py sha256=5-1V_juSsWUV-0e0F4egSYjJvXcBOJF-fzLyBXhywts 2874
kafka/metrics/stats/max_stat.py sha256=jBkG-ozWpsH1qmPNzhiICpJVKxwbep-VHwOEGRnCHJo 546
kafka/metrics/stats/min_stat.py sha256=gI0d7RUJB5En7PS_TT3WZ_gJl8tOZi81o-F0JD3S_oc 568
kafka/metrics/stats/percentile.py sha256=ZQoda6vpS9v5LopQJL64SyCWO9160SVELxQ9S1KKit8 342
kafka/metrics/stats/percentiles.py sha256=G93lvde1ooWpLb5EufPUErTQ_WJtTh1cZ9MkaOM2Qp4 2898
kafka/metrics/stats/rate.py sha256=bZ35sNpGqKSgMrtvqfFsYmkDnbZ_Du9NYw7otYV4Kkk 4530
kafka/metrics/stats/sampled_stat.py sha256=rb42q6MIkAm2LJh4H4QoC6OmP_zJ-3jbBrva0kf_0J0 3458
kafka/metrics/stats/sensor.py sha256=g4DvfsPGE9v8_4MX9jBBplWAh17Qd5LZIs0KyQ2yUg0 5126
kafka/metrics/stats/total.py sha256=tUq8rPW96OVzjVz0aOsBkEe2Ljkv6JaBa5TMCocYydg 418
kafka/partitioner/__init__.py sha256=ZSJilbRg8K6MIpdfYLPX-hZDt5fuXh6lVJbnmyqhEV0 336
kafka/partitioner/base.py sha256=44aX8hksWyym7fg2GzeNRXrozA1DRsDF-vioXm4lOEs 906
kafka/partitioner/default.py sha256=yrqpmIhmG6voane4ldF-2MOVm9R3A0cuReYhu9LUoQk 1021
kafka/partitioner/hashed.py sha256=btIDpLS7YTjUB4tc9CImepYSnxzg2W-TC-1oLozvi88 3263
kafka/partitioner/roundrobin.py sha256=TLCFgFtPwH2_XjynANPEsTp3TuWNK8rPVx-oEZiWYKI 2400
kafka/producer/__init__.py sha256=VE40ZZZMh7Wu--yslXqIVEwZ-ioEVnIy7clMqWVit5s 228
kafka/producer/base.py sha256=b138mu5oNRl-pzZHAZNUFULwdXZZaoKuvAHjt5dkw2Q 20199
kafka/producer/buffer.py sha256=QwNKjXL1TD9OaVrhwT12rwIO80QkUjWNN0mI5CTNv1I 16780
kafka/producer/future.py sha256=ilaLC_Qm7FgfXQ2IENT1gnusDrfbqHcDzonfpXScPtU 2680
kafka/producer/kafka.py sha256=-FSbacXhUH_S3pMQcoyZtwnIl4C5UuY5-MC5JGyB4VQ 33379
kafka/producer/keyed.py sha256=btC524vT87jSFTTx-GkcOdaLk6pquxcAZL0cTaxWf9E 1671
kafka/producer/record_accumulator.py sha256=KwlGmYd5Q38p_hZd3TDPLdD-_GBAlsmKfO2Ya6anbHA 25105
kafka/producer/sender.py sha256=_z5Sk0zA6TV6ouBjwVJ21UmeTC_Bgwc6SBYbkVK6ulA 21529
kafka/producer/simple.py sha256=uagpl5Gg6sDfX4drGO6m5pgKZf9zYOowgvdDxtG_EXE 1827
kafka/protocol/__init__.py sha256=eJS5qJRmx3V5WaB-wMvEdUydFX0qNTOjz2wKFX2QC4I 1069
kafka/protocol/abstract.py sha256=LUYVZkjlEnZzvklkgrsfz8iZKNSFhS8cP-Q-N0jqdQo 385
kafka/protocol/admin.py sha256=xu2NEncRR-VFcs_BfiZrSzT-Y0DXeZYW8TxpJ8Xve8E 7824
kafka/protocol/api.py sha256=we1VJBvjl3QCtBuWOotoBvppjt-o2gzYiBoMYAvWUdc 1655
kafka/protocol/commit.py sha256=k4Yd1RLc-TPUWzkbkHnv34f30mCOUiIEXGui--vWuqE 6860
kafka/protocol/fetch.py sha256=B5yRh6fqyJmBjPHuOj-wjJudwCxPh9TSI4xlRErRjuY 5108
kafka/protocol/frame.py sha256=SejRBK5urTD-2UzcVM2OxTgC73qDxfF3nlBPl9sjsfY 734
kafka/protocol/group.py sha256=fXOLbv0yULDAZoWBdRHql7SeRmLEVFtzaK_D_N8EaEg 5550
kafka/protocol/legacy.py sha256=PDRmRviHZuy9PwzsAty8dxP62QuhwInnVfl18FYlYOI 15842
kafka/protocol/message.py sha256=nfs8TJrHdUCGIwfysKqQAdwbjFqtUIzEk0-efL_KE44 7240
kafka/protocol/metadata.py sha256=QA4gQCwxLo99MCx5BAF_a6Ioe6lssFcls3YgQQDqKWs 4793
kafka/protocol/offset.py sha256=0_Shu4CWfuT-upPLwypwJVAzAs9srULFFXpONkaU658 2745
kafka/protocol/pickle.py sha256=FGEv-1l1aXY3TogqzCwOS1gCNpEg6-xNLbrysqNdHcs 920
kafka/protocol/produce.py sha256=Gm1TzHqmh0Rotllb7TMK_Rh4Jk_b3Xq1SDMFWh1oDqY 3232
kafka/protocol/struct.py sha256=eFyqcDaXTovMNsdh-gfaDj6f3Fzknf8UJ9x8ozu9S1s 2448
kafka/protocol/types.py sha256=5h2z3X_TM1y8B1MFIOhdAl7giaQdWvwruy3pF2AHjKg 4488
kafka/serializer/__init__.py sha256=DZONjHRwyGBzFwn5mDrlY0Yps3BiFs6XdmGF5ObPVOA 87
kafka/serializer/abstract.py sha256=doiXDkMYt2SEHRarBdd8xVZKvr5S1qPdNEtl4syWA6Q 486
kafka/vendor/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka/vendor/selectors34.py sha256=40NdCvzBONYxE_IEQlvLma7Zftl_pCnkUEQPGTT_JOk 20502
kafka/vendor/six.py sha256=6UsB4PtR8s6GpGjANVQNchBSH2M0mguKCdur98DUSUM 30197
kafka/vendor/socketpair.py sha256=b1xkZI3Xhx3mUHIkZkOeXKkr0o9tRpZQCigQ6Dv7Xl4 2117
kafka-1.3.5.dist-info/DESCRIPTION.rst sha256=ILCd4nmKjQS5OfhIbbNmykgzxwe5x7Ujt3vlhm-Z398 6037
kafka-1.3.5.dist-info/METADATA sha256=Zywfn0zzDyHntrrC48aTNWn1mClluNjBAsnWrW-O_9w 6949
kafka-1.3.5.dist-info/RECORD
kafka-1.3.5.dist-info/WHEEL sha256=o2k-Qa-RMNIJmUdIc7KU6VWR_ErNRbWNlxDIpl7lm34 110
kafka-1.3.5.dist-info/metadata.json sha256=J1OqtSQCRyZUYVxtmo6dGiHarimabq6h6KkerIGTbbw 1067
kafka-1.3.5.dist-info/top_level.txt sha256=IivJz7l5WHdLNDT6RIiVAlhjQzYRwGqBBmKHZ7WjPeM 6

top_level.txt

kafka