Wheelodex » Projects » kafka-utils

kafka-utils

View on PyPI — Reverse Dependencies (3)

4.1.0 kafka_utils-4.1.0-py3-none-any.whl

Wheel Details

Project: kafka-utils
Version: 4.1.0
Filename: kafka_utils-4.1.0-py3-none-any.whl
Download: [link]
Size: 171023
MD5: a58fea6a86f8a0e5370f4967c79cc5ea
SHA256: 3cf918f13991d9ff2d87cf7922f22642508317dcc1e93f52cbc22c282a18368b
Uploaded: 2022-11-07 23:04:32 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt

METADATA

Metadata-Version: 2.1
Name: kafka-utils
Version: 4.1.0
Summary: Kafka management utils
Author: Team Data Streams Core
Author-Email: data-streams-core[at]yelp.com
Home-Page: https://github.com/Yelp/kafka-utils
License: Apache License 2.0
Keywords: apache kafka
Classifier: Development Status :: 4 - Beta
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Environment :: Console
Classifier: Intended Audience :: Developers
Classifier: Intended Audience :: System Administrators
Classifier: Operating System :: POSIX
Classifier: Operating System :: MacOS :: MacOS X
Requires-Python: >=3.7
Requires-Dist: humanfriendly (>=4.8)
Requires-Dist: kafka-python (<1.5.0,>=1.3.2)
Requires-Dist: kazoo (<3.0.0,>=2.0)
Requires-Dist: PyYAML (>3.10)
Requires-Dist: pytz (>=2014.1)
Requires-Dist: requests-futures (>0.9.0)
Requires-Dist: paramiko (<3.0.0,>1.8.0)
Requires-Dist: requests (<3.0.0)
Requires-Dist: tenacity
Requires-Dist: typing-extensions (>=3.7.4)
Description-Content-Type: text/markdown
[Description omitted; length: 2829 characters]

WHEEL

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

RECORD

Path Digest Size
kafka_utils/__init__.py sha256=PnJEJK92PgTL-Pi1NGek7fuGrd-1YVq1IqfHXJpeVNY 595
kafka_utils/main.py sha256=2ewRt2lHPGntMTjC8iZ_i5sSgNvuE4OsjIDjD5ASIHk 1892
kafka_utils/kafka_check/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_check/main.py sha256=pQQPG-75NMJhibTSefXr9pn6Me_QpJfhwAwBcJ6rAY0 6293
kafka_utils/kafka_check/metadata_file.py sha256=zQjUeHiJqtdkOE8ccu-jvEZ61WwyN6IlZ_Q3IJlusAE 1643
kafka_utils/kafka_check/status_code.py sha256=wYZuwhMlh73zjTpeMgyvTSBsjIn-N7fHaWOcgWo4D9I 1497
kafka_utils/kafka_check/commands/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_check/commands/command.py sha256=dAkp29PP2TK-ETDFMgNXR8MuOJkCUdbBPiLLUpwoPu0 3955
kafka_utils/kafka_check/commands/min_isr.py sha256=96zOS506ffroqFUvFZv_cP4ADGhBsk9SHzoPRUB51nQ 5017
kafka_utils/kafka_check/commands/offline.py sha256=5E0VqLHRstuc5ySM9zKfmwvXiRomV1rxCkT70Vm8eXc 3068
kafka_utils/kafka_check/commands/replica_unavailability.py sha256=z295FLoezV4IXu_CE_PrtADCWkz0MA-LLnHqabhMcRQ 3585
kafka_utils/kafka_check/commands/replication_factor.py sha256=TiTy4_V4hd-DooSQgcUaHzrfbpIg-lpmCsd0_YbuZuY 4640
kafka_utils/kafka_cluster_manager/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_cluster_manager/main.py sha256=xn2h02eNTzeB-XqLpXwANkswa3UQSbbcnY7DY_TSB-A 8253
kafka_utils/kafka_cluster_manager/cluster_info/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_cluster_manager/cluster_info/broker.py sha256=P5N0FBPSpPtAAb57DEQONRpjhDtqewwCmggwC1PMMd8 14337
kafka_utils/kafka_cluster_manager/cluster_info/cluster_balancer.py sha256=mk_5v9mrXVrUNaBoOyVsdpXnh61i8yGlXYWp_Tsyf3M 8440
kafka_utils/kafka_cluster_manager/cluster_info/cluster_topology.py sha256=mPzsPBu3ozwmnnUIreaJOm7z1b86qXLAZCBkreGPb3U 9842
kafka_utils/kafka_cluster_manager/cluster_info/display.py sha256=dA1IO1tYOdRaPQmCeQDoAQaDHoFzEpYK64ripncSyJI 14798
kafka_utils/kafka_cluster_manager/cluster_info/error.py sha256=ufKt0j5GzdBK6gKsOipoSQ4X7OA_h1GE0k_NtjjdNII 1787
kafka_utils/kafka_cluster_manager/cluster_info/genetic_balancer.py sha256=dOxDCCyVTYpuemmkTxYv-BRVgdMvDCe2gMR1qYbQbD8 46088
kafka_utils/kafka_cluster_manager/cluster_info/partition.py sha256=b45C9Kn9NxnUzk6RxMLU4-3-1-u7_1dXTw9HTJgmJPY 4863
kafka_utils/kafka_cluster_manager/cluster_info/partition_count_balancer.py sha256=OiYKy-5qR5eolSTDI_1C_D_v7PqQGKLkq_DbxLCIiuo 24619
kafka_utils/kafka_cluster_manager/cluster_info/partition_measurer.py sha256=rmd_Qo0ubW80BVgCWu_Nv_gbSiz9EfSrTev0NtaXKrU 3197
kafka_utils/kafka_cluster_manager/cluster_info/replication_group_parser.py sha256=XXChvtSYp-SZnYLyTts_j6pEEFsQ9onh4pPmG6culO0 1743
kafka_utils/kafka_cluster_manager/cluster_info/rg.py sha256=ayHWIkCgfas99Qc7HsC0voSZs-r8d4WSGPdRPXIrHpQ 18210
kafka_utils/kafka_cluster_manager/cluster_info/stats.py sha256=BnMjc3Xo1hBpIgf1_dGqv6N5xXUXF7SaUoVyhlj6mrA 11162
kafka_utils/kafka_cluster_manager/cluster_info/topic.py sha256=RIslLKyEEqlVPjstoiZPHTwBnvKrlmdqCbcDvP-1tw4 2125
kafka_utils/kafka_cluster_manager/cluster_info/util.py sha256=_um0qP5T2DD8wVljSrqkKqlKUmn5rSv8NVCzMVMLIdg 4244
kafka_utils/kafka_cluster_manager/cmds/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_cluster_manager/cmds/command.py sha256=ManMs-CDl1J22gqRCo_IQY7738_GcWYMl7Cf4GUcxW4 13589
kafka_utils/kafka_cluster_manager/cmds/decommission.py sha256=FCbYnbhVNaiQvq4XFHOQG919Otw4wqfkw65YwG6b-X8 7563
kafka_utils/kafka_cluster_manager/cmds/preferred_replica_election.py sha256=4HrIjTlSbukZ0JriAifH342fVnasjjR7MdCXL1yBZtc 2667
kafka_utils/kafka_cluster_manager/cmds/rebalance.py sha256=Bujk2XrbQiDKhVYfWwLjs7IqQNvx9n1E5HxGUPe0BLk 10628
kafka_utils/kafka_cluster_manager/cmds/replace.py sha256=sAtjtybRu9QRQDmFsqo9JrjqdoPo-7nTYevEDa14r6I 5562
kafka_utils/kafka_cluster_manager/cmds/revoke_leadership.py sha256=PkphtlNIcZv32QnbGDEKNTK98XTby_P-5pXax3Q0bbE 3061
kafka_utils/kafka_cluster_manager/cmds/set_replication_factor.py sha256=L7PcrXU4LgrLw493qGbE-uARypO2BsTZgHhpBw0a3n8 5766
kafka_utils/kafka_cluster_manager/cmds/stats.py sha256=74Uaiabyrr0I0r_Nn0J-C8HESeBIaxYzZWSJziwFckA 3536
kafka_utils/kafka_cluster_manager/cmds/store_assignments.py sha256=12E1hmM7KNWLHB4DFyrDH92gwNlx-uM6tdnsCbIFOC4 2519
kafka_utils/kafka_consumer_manager/__init__.py sha256=PDQfpDiScg1TXkid1waaN9zbmxKDVjIgWtNrWkS7oNE 595
kafka_utils/kafka_consumer_manager/main.py sha256=UjKIVHtYkdzLpKK3SZe4jIkn45eM1dwGOH-504OGTu0 4200
kafka_utils/kafka_consumer_manager/util.py sha256=6iBGRCKpGqlWed186XUUhIEs3f2H0G2UHvEukMRT9eA 18320
kafka_utils/kafka_consumer_manager/commands/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_consumer_manager/commands/copy_group.py sha256=vROMlbDEtG_mGJIxxxngLtGsLaK2xRtKA7hZnp58RKU 3236
kafka_utils/kafka_consumer_manager/commands/delete_group.py sha256=Q3sfkAf45x76k_FfqiF2KEMpkJL_s2rCLZMbXI-wPdM 2368
kafka_utils/kafka_consumer_manager/commands/list_groups.py sha256=PAOohjiYM4MQyY1mBtn2rNu7TjL36ifJgXs_iG44blM 2447
kafka_utils/kafka_consumer_manager/commands/list_topics.py sha256=sbBz1TXEfR-NfTsIMnHIRCLKFpzJlzHtgEFXh787uK8 2307
kafka_utils/kafka_consumer_manager/commands/offset_advance.py sha256=QZcvD4D1ui9VKLNtRzCK0u5neeBYn452iVf4kd5hpjY 3777
kafka_utils/kafka_consumer_manager/commands/offset_get.py sha256=NQcvpIFIDVKRx5usBuhgeCYRyHNc2D2P6xx47OPdXu0 9714
kafka_utils/kafka_consumer_manager/commands/offset_manager.py sha256=R4rhZ6Po80NaKzrrKknCLMvA9zO5oGA12pc0RW9lQSA 8691
kafka_utils/kafka_consumer_manager/commands/offset_restore.py sha256=uM5Nkvx4Ws0W4ckzHSerxrB1y3NV80Tqvx03aCKORfk 7793
kafka_utils/kafka_consumer_manager/commands/offset_rewind.py sha256=SBBHis3TlF1ARhWi6LzFCVpM2OZHNZG3z5W4vzYQ2Eg 3085
kafka_utils/kafka_consumer_manager/commands/offset_save.py sha256=tBA8H9onl5XQV0n5R1GN4RQknLlcJUFpTOt4SYZGe9Y 5279
kafka_utils/kafka_consumer_manager/commands/offset_set.py sha256=PU5qXHYMAle1hY6heM87M2apTR4kO8VX8HdNWjaIDag 3955
kafka_utils/kafka_consumer_manager/commands/offset_set_timestamp.py sha256=LJLohBRgy_rhZ9NKvA_A55zGF_K8WZiDlPQjhaWUPlk 7399
kafka_utils/kafka_consumer_manager/commands/offsets_for_timestamp.py sha256=g3K5o4bgeOeDj451Ztnc5BC9FbCIDp_lEhzUnezzyKY 5114
kafka_utils/kafka_consumer_manager/commands/rename_group.py sha256=5TTherN61yEkEIMi9YN8WvfXyWQJK2CaXBJcuDAHt_k 2961
kafka_utils/kafka_consumer_manager/commands/unsubscribe_topics.py sha256=uQA2DjfU7upNKSoJRXU2ZekDNu2sD8qJJPIf5gWPfAI 5964
kafka_utils/kafka_consumer_manager/commands/watermark_get.py sha256=ltTsyVAaMY0wYeJIrRF0mwLu9hcSinhtedMlKymo2lw 3826
kafka_utils/kafka_corruption_check/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka_utils/kafka_corruption_check/main.py sha256=h-8wT4N1Kx3cbhyN-eMGu4QIkHdVWBPhai7W-KIJECE 17028
kafka_utils/kafka_manual_throttle/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_manual_throttle/main.py sha256=ohxtehbtWjWzklJeF1siAuvIPC6IiVQWMiFpv87itCY 7748
kafka_utils/kafka_rolling_restart/__init__.py sha256=OYuBcju8dGNP4DnHpVdeHIDRT74vkC-8u4lPtrNGCFA 573
kafka_utils/kafka_rolling_restart/main.py sha256=e4YxLu0ejuZtzk8UmEJtQKqM8Vq0mrv6K7igr9BjPio 21780
kafka_utils/kafka_rolling_restart/task.py sha256=XbacFo52mhsH1mVr0iXn4n6QMfywSPdMvxi-zIMxJmU 1633
kafka_utils/util/__init__.py sha256=Wjzdz29N6SgTp1bhGwcTSV5cB7RkTBUrLLcqcjOk5u8 5130
kafka_utils/util/client.py sha256=Q-sxItAKO8BsCyOQ3BAj6zbKsMxBSKQ78WmPNdFvJyo 7407
kafka_utils/util/config.py sha256=2PaJJyIJMnEl7Yg1KeFF5O7B354SJB3xriuJJlzZt7I 9577
kafka_utils/util/error.py sha256=Ga6jZSaxdpQWiyRupH6bE5FJr1uXAMDntzQ4pvSBcRM 1945
kafka_utils/util/metadata.py sha256=9nljlOSirbSWUJexjUD0_xEoq_YcLkwTueeKa4aUxh4 3542
kafka_utils/util/monitoring.py sha256=pcK41HsqaC-oZkSrdcc-VZVCYGd9_bXdQUk5XRIysDA 6137
kafka_utils/util/offsets.py sha256=Phi4xLaAUx6rdTxg-O26Kk7VtNGE30_Yt6A9CZzXg9U 19157
kafka_utils/util/protocol.py sha256=N2NiXjW_rH0I31prTsBn8Wx-Pcxpus53fljqT2z2QqE 2955
kafka_utils/util/py.typed sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
kafka_utils/util/serialization.py sha256=iuardcTLHGj7eDPeih1wyFOC4AYIbwcb7rWUea_dWdI 836
kafka_utils/util/ssh.py sha256=CywyRfHLAXSoH0563JMzXZSxUZa-UA2jbl7ToMKhQig 7198
kafka_utils/util/utils.py sha256=H_2PuhZ0rKxFeimveIQB_uZnkb3G9R6C7ABZyZjNzrI 2521
kafka_utils/util/validation.py sha256=QVMeEGqUR-rhEzn5CUDgrfL_vXq3PhFJR__fu3N9w1I 11068
kafka_utils/util/zookeeper.py sha256=ToQc81ZRLivGu0Fcy5WrYyWbRI_l32lLUjKD17GTb8g 25006
kafka_utils-4.1.0.data/scripts/kafka-check sha256=xNGd_uMsg3I57OVrBCbyBF0xDCtliBYayIhvropbMBw 93
kafka_utils-4.1.0.data/scripts/kafka-cluster-manager sha256=SdKsE42Ks9O-07rE-Zmzj32cqDmGZzZUVs403-NAv94 103
kafka_utils-4.1.0.data/scripts/kafka-consumer-manager sha256=dVF7nP_pq2N7OyOBWxggSLN0olf9G2K0h0q5QF5Wbm8 104
kafka_utils-4.1.0.data/scripts/kafka-corruption-check sha256=VI_Gl7NgFaTO1GBLDRBZveAf_8fhvJtBgfHkYsuz8pw 104
kafka_utils-4.1.0.data/scripts/kafka-rolling-restart sha256=ccPw8ZdBnxKa5k3jCYM_mvP53JItzLpoq9Gs_LTZNzc 103
kafka_utils-4.1.0.data/scripts/kafka-utils sha256=ShsYxk4uTFvb1KtBYndA_X_Vli8uoAIqcdGWuksrSLQ 81
kafka_utils-4.1.0.dist-info/LICENSE sha256=3c79CoKtqNPzBc9QcP4g3J5OC1NbEh6opqbRwuKaxWA 11342
kafka_utils-4.1.0.dist-info/METADATA sha256=MlSmebTyvcW4_goFCGfbof-UA5r4kAw7Ldn4ZABJYEQ 4046
kafka_utils-4.1.0.dist-info/WHEEL sha256=ZL1lC_LiPDNRgDnOl2taCMc83aPEUZgHHv2h-LDgdiM 92
kafka_utils-4.1.0.dist-info/top_level.txt sha256=xibRWgt93zHtl4yx1hwNw9Emyo9j1Iui1yH2VW0ol1M 12
kafka_utils-4.1.0.dist-info/RECORD — —

top_level.txt

kafka_utils