Wheelodex » Projects » kafka-python-ng

kafka-python-ng

View on PyPI — Reverse Dependencies (3)

2.2.2 kafka_python_ng-2.2.2-py2.py3-none-any.whl

Wheel Details

Project: kafka-python-ng
Version: 2.2.2
Filename: kafka_python_ng-2.2.2-py2.py3-none-any.whl
Download: [link]
Size: 232369
MD5: dfe9b97a6e72039b051115c3bb0db7a5
SHA256: 3fab1a03133fade1b6fd5367ff726d980e59031c4aaca9bf02c516840a4f8406
Uploaded: 2024-04-10 17:03:00 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt

METADATA

Metadata-Version: 2.1
Name: kafka-python-ng
Version: 2.2.2
Summary: Pure Python client for Apache Kafka
Author: Dana Powers
Author-Email: dana.powers[at]gmail.com
Maintainer: William Barnhart
Maintainer-Email: williambbarnhart[at]gmail.com
Home-Page: https://github.com/wbarnha/kafka-python-ng
License: Apache License 2.0
Keywords: apache kafka,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 :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: Implementation :: CPython
Classifier: Programming Language :: Python :: Implementation :: PyPy
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Requires-Python: >=3.8
Requires-Dist: botocore; extra == "boto"
Requires-Dist: crc32c; extra == "crc32c"
Requires-Dist: lz4; extra == "lz4"
Requires-Dist: python-snappy; extra == "snappy"
Requires-Dist: zstandard; extra == "zstd"
Provides-Extra: boto
Provides-Extra: crc32c
Provides-Extra: lz4
Provides-Extra: snappy
Provides-Extra: zstd
License-File: LICENSE
[Description omitted; length: 7818 characters]

WHEEL

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

RECORD

Path Digest Size
kafka/__init__.py sha256=FNeyEJknsHsLHrQ-BVljXrcby9PBn3fO10lfQfax4Tg 1037
kafka/client_async.py sha256=u70_PxTRo1XADKbZORs6cLHhj-1Yd9XKb_Nh-sAnN0s 45889
kafka/cluster.py sha256=sEPh1JobtyMQR6_chheNJXu3pHDanCUmG1N4WQ8uTYQ 14724
kafka/codec.py sha256=APzLqjCn3enccZduO8sc1vZLRC9rXLuaye0jTyv3pG8 9252
kafka/conn.py sha256=dx8Q4_DSfDPyQePvenb8F2hEenVBlpqfaz8bS1cZxiA 56893
kafka/errors.py sha256=GD-GGsRU_YJzvfGg527CxKUVJouoq8qC5NfOW70Ome4 16212
kafka/future.py sha256=qDCpJ3wgF_qV-DhJBOPymCNGY-M4ppL6mxw_W7bpPv8 2426
kafka/scram.py sha256=fOffx1zWGAK4r8obR_ygqFKv5HEiDnriFv4-asQNW5A 2821
kafka/structs.py sha256=1u_20yFMgeTUgmu_1X0wwUxV_Q7Rr0G5gFgPYhvDCRo 2888
kafka/util.py sha256=kOi5H5rFGCgq5kClD5hyX4V5NPW488ohGYX48Clz_VM 1807
kafka/version.py sha256=1iaLn_f07-LoLv21weKuj_7DDlKsBqAw0gFhJ-fTilw 94
kafka/admin/__init__.py sha256=opYPJl2o6cwMxLqrb1dtKa2Lo-iRh15DAsRJe8-jJcc 680
kafka/admin/acl_resource.py sha256=mmD5tok4J1KE0RhzNL6aU8cva-Wb6vqbq-rHUZ3_l-o 8007
kafka/admin/client.py sha256=Z8Ntc87u1My-PfT1NHwyU7hWaYYziEtmyv9R9dXhTUI 64300
kafka/admin/config_resource.py sha256=B7WRYU0E20eWNbP75aC3HUdZK8ygchozbB6HmrCyoPI 826
kafka/admin/new_partitions.py sha256=2ovXlprU9uMPbm03pycueJTI9A2Jc172gopMukmY0Qk 708
kafka/admin/new_topic.py sha256=ZfZjB7vpdlKnFQVmQTC6IoznjVmS5uu8sejHUToiK9M 1258
kafka/consumer/__init__.py sha256=I7nuPUb103S1CvCqcudbIRG_isJbRgTXkK1mpHIhoVs 82
kafka/consumer/fetcher.py sha256=QU3JGQkGEjTexoe133rJ14S_412GQJ3MSEOrU27y4n4 47504
kafka/consumer/group.py sha256=Z8DnDc-vxsHB3N7X7o0hb7E8_NT8YAu6jTWXHCmHXF0 59428
kafka/consumer/subscription_state.py sha256=5XhZVkO1fAQt_7kwVP--KXjsFlMKRh-z72vt6-5dYCk 21495
kafka/coordinator/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka/coordinator/base.py sha256=faohD-BTEoXu_t39hI4rPaTwA2SZeKbb_MkNh-Filkg 49041
kafka/coordinator/consumer.py sha256=8Jme6QW0TgH2qaYN2TI2ibUB-C_K6pMwbHpYBh8KJMM 39291
kafka/coordinator/heartbeat.py sha256=ATSAzBAdfpWaJspLM2yJ8W930Hq17u1fmh1Rq3XBMYk 2246
kafka/coordinator/protocol.py sha256=S3Di9GhA_YPDFtDoj_Pu8mBgbky221VMKq7s1uiHg1I 993
kafka/coordinator/assignors/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka/coordinator/assignors/abstract.py sha256=ibp-83G3U1yue4CGCVUMzC8BR-sqYJTlzFnf_SmLJOk 1505
kafka/coordinator/assignors/range.py sha256=R1R9PNfDY7Gi0tD_swFSWuMXLFE6Y_Q8WM8hAcgVjVc 2828
kafka/coordinator/assignors/roundrobin.py sha256=AM5yGSMJsrVSGQ0BKuOQFF6etW-4dq_FUXgUZc8POAo 3699
kafka/coordinator/assignors/sticky/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka/coordinator/assignors/sticky/partition_movements.py sha256=9py2yngWsz1rOenM0zn4lo5S29FmKkDV1JDzekKZhT8 6439
kafka/coordinator/assignors/sticky/sorted_set.py sha256=lOckfQ7vcOMNnIx5WjfHhKC_MgToeOxbp9vc_4tPIzs 1904
kafka/coordinator/assignors/sticky/sticky_assignor.py sha256=4tlIp8BnmR-HPDjhO6pXXgx8-HMi4qmXz6WgtsUv4eU 34038
kafka/metrics/__init__.py sha256=hfLNpXZF1IKu-Hr-wrz1g0cWRG1xBMc4LJbjWmT9O8Q 534
kafka/metrics/compound_stat.py sha256=kc5aLFnqnmJYLwdv7TQNwM9BP0RQRYfdqmBrA3SetQ4 728
kafka/metrics/dict_reporter.py sha256=MtVHG859b1Sc3rc4oxnmW0tQ8jhyNUyRg_JJsVF9Qvc 2509
kafka/metrics/kafka_metric.py sha256=ONgF5NGQmmzujg-X248rY84ztD0j9b3U_xO2yemNF7E 885
kafka/metrics/measurable.py sha256=1kKj1N0a-D39c51uzyJiR_mT4rnPXfF7LjYxwSOvnXA 722
kafka/metrics/measurable_stat.py sha256=BTxYTrjXXJLCh_qZ6QC5gHha2d6FbU4_BTgbEbZV9jE 463
kafka/metrics/metric_config.py sha256=24hjIuRTK7VMRM6jtcB7zcnMX9otvPkbLmUF5oBZqK0 1106
kafka/metrics/metric_name.py sha256=g08R9Y5HyX3LCs-C6_38xLo9fyLHFkIRL42dclsedoA 3375
kafka/metrics/metrics.py sha256=vVCxrS9PGTRycpdh6Sh1ivCqkNh9U-RJU7A_4cTj0bo 10258
kafka/metrics/metrics_reporter.py sha256=n_k3klLEOCJ8asXBz-uhTTHuts1733HtniswTrRqhPo 1350
kafka/metrics/quota.py sha256=4kOmlmANP3g-j7cg4HJXHtuplR-Tswc7HhIL8DKTlrY 1079
kafka/metrics/stat.py sha256=uc6Jt2eSGXgo6pnfMa1FE9vCCrxtMvQHZdTU-ORf-D4 580
kafka/metrics/stats/__init__.py sha256=sHcT6pvQCt-s_aow5_QRy9Z5bRV4ShBCZlin51f--Ro 629
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=n4Uqt7qyRUkrkOWZvymfKx-7ANvopDXgLeXH1QRC_rk 2901
kafka/metrics/stats/rate.py sha256=-zkYp8kZrhy01hDaPCYcKqvRycY1esyNPRQrqK_JH5s 4533
kafka/metrics/stats/sampled_stat.py sha256=rb42q6MIkAm2LJh4H4QoC6OmP_zJ-3jbBrva0kf_0J0 3458
kafka/metrics/stats/sensor.py sha256=sxX2SxkTOuLA-VPIRu4LyJnJYsqpvEybd6oiVS2Lf5Y 5129
kafka/metrics/stats/total.py sha256=tUq8rPW96OVzjVz0aOsBkEe2Ljkv6JaBa5TMCocYydg 418
kafka/oauth/__init__.py sha256=o44ZgmuapbZ3mKS53vfdRXi0MoF8kLLxiyG1LhskNOU 55
kafka/oauth/abstract.py sha256=EtCJ8RtAYNLSQTnC-bpcQykdEPiO5oCc4J3a8mForyI 1256
kafka/partitioner/__init__.py sha256=S8AR1Qt8XQAhkSJQR7IT_bRVsAAnZuZ3iPXNgIuxK58 118
kafka/partitioner/default.py sha256=_Y7k_p3f9fnOXItPN8gXlIAbGQp5aOfas-yhQZwprt0 2633
kafka/producer/__init__.py sha256=OPWP89JbP1dCYG4HSWl1iz6KLun0oJDYfqLAr0vAfHQ 82
kafka/producer/buffer.py sha256=Ye4GC7b6Km5KjZrHsLo_b4tdh0ijgj9sCeKvCqOiHq8 4312
kafka/producer/future.py sha256=aecsLb3fwdZjig9DdalQ95-iXaNEgopSLmM8rW0-lW0 2893
kafka/producer/kafka.py sha256=6dal3F8kzw6vGZ_kJCSmgZbA2U7sd-P3siJbI4oiqbM 37865
kafka/producer/record_accumulator.py sha256=HAjHszSvkexTArnv_3i6WQcE3OAKRFySBW6JIWu-0ig 24926
kafka/producer/sender.py sha256=L8EHJq-VponWdjGwV5uM3ZOMk6gGqS6DjZ16tGeEf_A 22820
kafka/protocol/__init__.py sha256=kjyN1MCubyifdSMRbCg6hYEpgXCw0yvF7HqIFQ0g5pc 1143
kafka/protocol/abstract.py sha256=lRLTLMHM5ujh1xg9Rav2XJTBrrUWTHoapd0L1hj0E9I 337
kafka/protocol/admin.py sha256=RldFhuNXqRXrpvNBnC3wB9PYGsuxpgA4OmTPTTtcjVw 29905
kafka/protocol/api.py sha256=lkAYfA2oxUa2tBXGTWjSWv8QhBHKlcxNQyxWBZFTcQw 3657
kafka/protocol/commit.py sha256=_ZzTVmY3VCKRYvJ-JyWAVY3myENRfgQ4P3xKI5m13Ns 6848
kafka/protocol/fetch.py sha256=nkRORLVyj2R7d__32GagKdf87CVqRHs1uKs-PylXLUc 10974
kafka/protocol/frame.py sha256=exKvWkszmCgkDpjlUQv-Jyz4_mCQwnQmgFx4QtJ4ZcI 718
kafka/protocol/group.py sha256=hK13DP8AkrEIUuWdwKZTvSDZDJ-D0A-hnIPCcGMS-UU 8414
kafka/protocol/message.py sha256=SVp_oDxmme79izOFcD7ubAUb4P2lLWS_Fe4YKb3A1iQ 7607
kafka/protocol/metadata.py sha256=pAuPP7Fd3_n8KFOmEKeSz8TrH5O28FxsvqZ5SOgnySM 6076
kafka/protocol/offset.py sha256=Y9rKn-bnuZjpfQSJE6Df1QGu9kTEp915NFEMghfLfgE 4659
kafka/protocol/parser.py sha256=BL0PxgS44O68wfvIk0tj4EPp9ETq6tcZmyMEKqYFp3g 6800
kafka/protocol/pickle.py sha256=CDVUAvvLAxmNp6TR5qHp9YrUyCiXK6k7upX_Gc040uI 880
kafka/protocol/produce.py sha256=is8ar-txnFSr5kH9PyTtWqN0x-BVHCNBxuuDapzlnTs 6420
kafka/protocol/struct.py sha256=aGSBG1Nour-wJKECLN1uF8mlQxOgCpOF2yinT7NOztA 2566
kafka/protocol/types.py sha256=kBGPfAZa7c65bmKhrXTNwlpWIA5hVxOpdDPVHPFjJ1M 10158
kafka/record/__init__.py sha256=Q20hP_R5XX3AEnAlPkpoWzTLShESvxUT2OLXmI-JYEQ 129
kafka/record/_crc32c.py sha256=KUhKS1kP3AxdubbmwQ0nk1WCuPN3mYE9v3uZes6ZuCA 5708
kafka/record/abc.py sha256=jYpg6RAStACi1ImEmZ7oITo7CZHeLWYXH7R4K7QneEs 3380
kafka/record/default_records.py sha256=7IEhGCLf6vpQuRFWjdYpVSNFmukTEPayVXTxEmbjD5A 22223
kafka/record/legacy_records.py sha256=8E5hvaqZ0sJR5xsLlwd6mmf5qbZo2sPRHRHzcHz-zLA 19254
kafka/record/memory_records.py sha256=Z9xJVThitbZSoiBnj8AUXXH7CS_XNqwlXod72-OVWDY 6727
kafka/record/util.py sha256=2KSmlksKe-0HSRkTevHQxuPT3xkhQ5cVdd3iwurflCI 3708
kafka/sasl/__init__.py sha256=zrP7hE5oNaY5pCuqSpkNTdUpqJLK0ibRfrBHXZGDvvw 1821
kafka/sasl/gssapi.py sha256=ZYTwft_IKMC8omFPmuMgxbZgy0BQ69_SPcddrKAUJrM 4114
kafka/sasl/msk.py sha256=q4yqO6qdW00d5qapyPlyZ9i4ssBbut8gBCoiCwCng0Q 7947
kafka/sasl/oauthbearer.py sha256=CsB_4Wy_J3BQM7I3wdaYUS-0Avkcbnh8TD9W5K8xEwU 2636
kafka/sasl/plain.py sha256=BwC_fEAGiw1jm_zYWjqF9WDF3yw5ps-XhVtRWqiUcBc 1980
kafka/sasl/scram.py sha256=PKVMWlMa17reXsqrGkyqhuntMCHPYXKojLF7QsyqR7w 2375
kafka/serializer/__init__.py sha256=e9MrIy3nANIFmgEIGoqTpy5pr5DPfbTa5hpo9lcyTXw 63
kafka/serializer/abstract.py sha256=id6NszLuORKmw6Jbf0J6ZixLzlhSIDuekFECMMAtvaQ 430
kafka_python_ng-2.2.2.dist-info/LICENSE sha256=KrcY2_AbbyVIpWwikBS96hmNAMYJqbtevJ9ghAvdT-w 11343
kafka_python_ng-2.2.2.dist-info/METADATA sha256=NaXxUVJHMLDHCiBwYMfxwaoOyBB1j3YKV4srBQDFW8w 9202
kafka_python_ng-2.2.2.dist-info/WHEEL sha256=DZajD4pwLWue70CAfc7YaxT1wLUciNBvN_TTcvXpltE 110
kafka_python_ng-2.2.2.dist-info/top_level.txt sha256=IivJz7l5WHdLNDT6RIiVAlhjQzYRwGqBBmKHZ7WjPeM 6
kafka_python_ng-2.2.2.dist-info/RECORD — —

top_level.txt

kafka