wunderkafka

View on PyPIReverse Dependencies (1)

0.18.0 wunderkafka-0.18.0-py3-none-any.whl

Wheel Details

Project: wunderkafka
Version: 0.18.0
Filename: wunderkafka-0.18.0-py3-none-any.whl
Download: [link]
Size: 104184
MD5: fd8c60b0b13785340b6c584679c45d16
SHA256: e0bf89ea39b9d3753daa839c7a26ee4d6433f955f780b98850bd52d4ecb39f4b
Uploaded: 2024-10-29 08:06:35 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: wunderkafka
Version: 0.18.0
Summary: librdkafka-powered client for Kafka for python with (hopefully) more handful API
Author: Kirill Tribunsky
Author-Email: tribunsky.kir[at]yandex.ru
Home-Page: https://github.com/severstal-digital/wunderkafka
Project-Url: Bug Tracker, https://github.com/severstal-digital/wunderkafka/issues
License: Apache-2.0 License
Keywords: kafka,cloudera,confluent
Classifier: Development Status :: 4 - Beta
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Operating System :: POSIX :: Linux
Classifier: Intended Audience :: Developers
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Requires-Python: >=3.9
Requires-Dist: confluent-kafka[avro] (>=1.9.0)
Requires-Dist: avro-python3 (>=1.10.0)
Requires-Dist: dataclasses-avroschema (>=0.53.0)
Requires-Dist: fastavro (>=1.4.7)
Requires-Dist: pydantic-settings (>2.0)
Requires-Dist: jsonschema (>=4.17.3); extra == "json"
Requires-Dist: requests-kerberos (>=0.13.0); extra == "krb"
Requires-Dist: python-dateutil; extra == "krb"
Provides-Extra: json
Provides-Extra: krb
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 6510 characters]

WHEEL

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

RECORD

Path Digest Size
wunderkafka/__init__.py sha256=m7rpPNaYsmhzYbR0dPlzzVEAhbstAjpvwfRXFH7K8R0 1178
wunderkafka/callbacks.py sha256=BZV6U6AaE8eDxig0Hcvm30x88eYCveH_xuqHYCY9-30 2605
wunderkafka/compat.py sha256=LiqNUJ6NdGCedUS5oCMRsgsuvjvov2LSdIjM-4MaZQg 127
wunderkafka/errors.py sha256=vvRwbHJ6A4fpjFrhbk6HSa6cob2b03a-H-UOLriRvt8 717
wunderkafka/librdkafka.py sha256=2FVuF6yHVz-iExUVz53YbPd0XcHWjJ1WqapR4NcAGBg 191
wunderkafka/logger.py sha256=XAlbkgi1LL6goDtefbcOrGvYJq0dSbj81ByNbYi22m4 101
wunderkafka/protocols.py sha256=Wt8ENqLC0YaLjFXijKwU0mvvXZl4MbkAGKDYyWAjLRE 2393
wunderkafka/py.typed sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/structures.py sha256=zfxk3go6RPqzUSo6WVpbGZpJx38IocIx2ePtYS3YsUw 2668
wunderkafka/time.py sha256=sDJs7w_avdkxN_nHeLZ9WfdIHw3g6b0bPQKquATOW58 939
wunderkafka/types.py sha256=Yv7cSI9CUpAYKdsojs5Bgq9v9h_3QRJKmHZ-c-DwJK4 822
wunderkafka/config/__init__.py sha256=92FhJ6CFq06Xo7uRHBGCg6UmxdeeUyIhn7_KcPVqTjA 70
wunderkafka/config/generate.py sha256=E8EXM6ovyDEan9L-UxFqDxepXUXmDC3jotZey1wRFEw 14221
wunderkafka/config/rdkafka.py sha256=4P4mOa8aPswf2NUqR3LbmCgNRkuQn-f33HTJHJ4ctdg 3047
wunderkafka/config/schema_registry.py sha256=Hyqy-qtn3f3vb9S7liOwoZzRghvF0edwLwt0tTrQfHA 1081
wunderkafka/config/generated/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/config/generated/enums.py sha256=UBsPtbED-5O6QtiHr0rwV77nprJVkZ6wCuVqyXRhU9M 11282
wunderkafka/config/generated/fields.py sha256=5nCnrVtLGtZ9IVQydvslWMSlg66U9z_56_Gz0KoRYHg 44283
wunderkafka/config/generated/models.py sha256=3wAkmgxPrCBlDqKqOswpDcjUm9_lUkmKudJl9NoSe-g 1554
wunderkafka/config/generated/models_versions/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/config/generated/models_versions/models_1_5_0.py sha256=bFGqbtWzZCy_Kdtj1U4Jp83-Kru7_A7PZBKkKbw4VKc 9314
wunderkafka/config/generated/models_versions/models_1_6_0.py sha256=U_q0W9lfQdgix1tlGTITGJo9N14CNkvDC3Yy6tq4HpQ 9459
wunderkafka/config/generated/models_versions/models_1_7_0.py sha256=V_EXWfS-22zTejEHDA6_F-_sTSeJsOItM0fsXH5swyU 9630
wunderkafka/config/generated/models_versions/models_1_8_0.py sha256=nVa6pFgTxUBsWKTTSzeNITiXAU1LM1YU9ilwB5MbsRo 9594
wunderkafka/config/generated/models_versions/models_1_9_0.py sha256=w-h6eN86zTxxhn3mb3xbsn5tA7qwmWCNVFwzJHshbis 10134
wunderkafka/config/generated/models_versions/models_2_0_0.py sha256=w-pIzjAMtmxh5QiRevj305WTD29tcHe6Ay33qL5nnww 10174
wunderkafka/config/generated/models_versions/models_2_1_0.py sha256=hf-cFE5bxjZuFVJ98KJVSkZtq0ImQ7mSpHZO78MfmDM 10172
wunderkafka/config/generated/models_versions/models_2_2_0.py sha256=H88S8gz-4KnpyAOrtQjaSd0wipPSH_yvO33ttd6S0Xw 10332
wunderkafka/config/generated/models_versions/models_default.py sha256=klRMTWN74keQfqiLsT6FzC6rr2o9iOZpaQgHg2E5xdw 9310
wunderkafka/config/krb/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/config/krb/rdkafka.py sha256=KPtIv3ypzmv4_Zym8SHCkxxi-RScCf0RO3S71P4jCPo 2000
wunderkafka/config/krb/schema_registry.py sha256=IYjZEQwfv_RK6zlUJPULVRGpTH6ppQCpIzUZHxHZ5qE 1097
wunderkafka/consumers/__init__.py sha256=YtDOPN4mod7vf9tLlLn_CbzD07c4kHO6rdJ8CEeCbVc 63
wunderkafka/consumers/abc.py sha256=SG4GsUpiDHMHx7TnSzsEtNaoRbvDlKZeeacAFfV7Wq0 4271
wunderkafka/consumers/bytes.py sha256=akqrpChuTO2vo1LBkO-1StGpR86_Hf2eI20zOk0jEAA 5958
wunderkafka/consumers/constructor.py sha256=_b5qF1CMZJphqBygtRdNrSLlYKS_eMhCdtTuImFk2QA 10055
wunderkafka/consumers/subscription.py sha256=9i3lBLL1tFJEYEvBLY2yj4JR-GQzYvrD3oU6pUpbs5U 3526
wunderkafka/consumers/types.py sha256=b4orsRKyMQAhvIcLT-qR4xW_9abOZ4I9DzKhCxiesdg 1188
wunderkafka/factories/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/factories/avro.py sha256=PCmbzXg59iEy8p69ytWaQ2ocBY6X8QnKlSI6iw3XVl8 8124
wunderkafka/factories/json.py sha256=SrM9wBCu5hc8TGDymVzue0MBNxkA35JeZnwrjbY-gEI 7716
wunderkafka/factories/mixed.py sha256=wVftux97D5ugW76-ESPuNxoUrEjB02L-fGB_-uKlyNs 8451
wunderkafka/factories/schemaless.py sha256=7pae--lSKcBkNJaIRHR2vXqh2x7i4zHuCo9BbHd3sT8 4199
wunderkafka/hotfixes/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/hotfixes/watchdog/__init__.py sha256=8FFGkD4zycIf4wMwoPZz1ae-6g3-UNnLnYbsVDvNXxY 7811
wunderkafka/hotfixes/watchdog/types.py sha256=vap6HeJ_Ge6PEcJsy-d42M7aD9Is1W5uYbxIX1Dn5tU 59
wunderkafka/hotfixes/watchdog/krb/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/hotfixes/watchdog/krb/ticket.py sha256=ChZZoDW9C-osJ0Q0G6FtShyRgRpIqzi4sEyYK0iCY1Q 4258
wunderkafka/producers/__init__.py sha256=IniU4C8IrYmjDPr7ttFyYe00h4K0cmv5czRT0DCyC6A 63
wunderkafka/producers/abc.py sha256=AlEfAUTW5QH9O2qHgskMzPUFr9TtmZ3rCv2CFT0ILc4 5033
wunderkafka/producers/bytes.py sha256=WtuleqK2nfTszOxQN3haS0tTH1Y1pV5STI-ZdXIswzs 2633
wunderkafka/producers/constructor.py sha256=AO3O88_uooXSAlt1_BF7VNaS-fjt3Q5OYn50pG_5Yzc 10805
wunderkafka/schema_registry/__init__.py sha256=Oh3B2WEUz6lPeAIyaCRyis3U6tBByx-wscOeUQP2dDA 281
wunderkafka/schema_registry/abc.py sha256=0UZhMkASOsTnetgzVwbgmEzuBWuC-TMJajPe75CXe_E 708
wunderkafka/schema_registry/cache.py sha256=PhW4XYupSWipSnPT8xl_UNU6Xn_4n2oGqmwPXPskqaY 393
wunderkafka/schema_registry/transport.py sha256=A2DFWPtO4av7biawFeG4VdMwni_7P0-bYSx0ap6-yZs 3009
wunderkafka/schema_registry/clients/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/schema_registry/clients/cloudera.py sha256=7nEahpNIRMqG0nhKvnn8FAdmc3uLaqwPAavi61fhpjQ 5983
wunderkafka/schema_registry/clients/confluent.py sha256=clLTbCp4jBsi8RWQLP6oRkdwSP_ebZYUmc4MjtkVABI 3225
wunderkafka/schema_registry/clients/subject.py sha256=MNHKFMYl5bEyXXfHvEMi8L4EqNFGRZ0FJD5kNRp5sdI 75
wunderkafka/serdes/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/serdes/abc.py sha256=cKKXLbEjvzFY0GUJ4SX3LWDr9_InDNT4sJy9ILoMMzU 2206
wunderkafka/serdes/headers.py sha256=O732qAc8X62Wq6P5Q3yfQn6GyBLXyiCrjQGpLskFYlo 2646
wunderkafka/serdes/store.py sha256=1hKs8TPjuqsO_YY8aK4--zi1VSKGOh2vmvErC2iWfF0 3940
wunderkafka/serdes/structures.py sha256=cne4vSj6Nnx_lPX6e-zqsyF8L32si4AENu0P7kmtfHU 449
wunderkafka/serdes/avro/__init__.py sha256=cxWC3NWzwUp_gTMck7F8LxqL1QnYy0GNGTYa0fKvHHU 211
wunderkafka/serdes/avro/deserializers.py sha256=o9mSHAhDG83J_4hxLy4VB_d3E57FqwhyiwxZtkwgTYg 914
wunderkafka/serdes/avro/serializers.py sha256=ZQQWP96Exe0ioxzThe-ZKyr2QJ6rlnLbu8Xa8Ax3-ZI 1057
wunderkafka/serdes/avro/types.py sha256=cPjyjRDD5LI04mwA4Gi3w1KgPGplkTGDJ2aDXiHE2T4 205
wunderkafka/serdes/avromodel/__init__.py sha256=sKbz6WR_djd6lW2E2P_vvqgO2JjCT7b-cdoBTl_eUws 63
wunderkafka/serdes/avromodel/pydantic.py sha256=_cavTKuVTcZXOuzaMl2H3RhP2buokn8DoDzAAVmpEOQ 5001
wunderkafka/serdes/avromodel/serializers.py sha256=RMh5yF5HOHlHe4WcJeX2s2JKU-1RzR9kZ_n609PNNSQ 935
wunderkafka/serdes/avromodel/derive/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/serdes/avromodel/derive/current.py sha256=9CwwNJT_1lOkyDUX9_X1do6w5wa1l-o7So_-QIkLk4k 3287
wunderkafka/serdes/avromodel/typing/__init__.py sha256=CN15fkbwWs7Wdof3nsIp-5-6scHYjGO15vgAbTg55k0 203
wunderkafka/serdes/avromodel/typing/compat.py sha256=0e0eGHQRyq7fU-3Oj2AFhpL9gF3OjP5vOQPUJaJ7U5w 1608
wunderkafka/serdes/json/__init__.py sha256=oxLGh48EqB4Nj2CHk0alPfsjVAbaGGsq3Bne6RoN6BU 154
wunderkafka/serdes/json/deserializers.py sha256=XvkXXWGT7ly_U2TVtUSbb9GEECM1Ld2FoB-8Kfrt-cw 672
wunderkafka/serdes/json/serializers.py sha256=TDsoKSthW0E4D6TOsUMOHOaNCJ2FGO-B0xgshptSujY 1498
wunderkafka/serdes/jsonmodel/__init__.py sha256=HUb06sUHEOsQBFizmrP0JNGuEYOJForLNqqyv2_5pV4 55
wunderkafka/serdes/jsonmodel/derive.py sha256=q-b1k6suUW8rC7dhYLz5qMuzL2YXsAPGEcw9d-Xdj30 1349
wunderkafka/serdes/jsonmodel/serializers.py sha256=mtX7-ChuJkyJkizmkOlippC9jtQj9KV9UHGVYilITqU 1456
wunderkafka/serdes/schemaless/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/serdes/schemaless/json/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/serdes/schemaless/json/deserializers.py sha256=tEwgsqt5cC0M3EjEtRrEGg2RXbU_fRxqNifh8sZfeOI 515
wunderkafka/serdes/schemaless/json/serializers.py sha256=HEn0QwVdEk1JR9iYnwc7Dy-rl7tt_UhIwfBV_Z6QwUU 538
wunderkafka/serdes/schemaless/jsonmodel/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
wunderkafka/serdes/schemaless/jsonmodel/serializers.py sha256=Mzz25owUgu5YukQRLx5fRmd0wHveI47YakUc6nS7sAM 536
wunderkafka/serdes/schemaless/string/__init__.py sha256=DyiRsSvXV8buGVZMli3Bwo4Ooed7nlMTERZjeZCY2R8 108
wunderkafka/serdes/schemaless/string/deserializers.py sha256=sHeOhdO4jAJcNDxNaS9VD1YlHNnzT9ARc-y5aQqHhIQ 478
wunderkafka/serdes/schemaless/string/serializers.py sha256=b0jkINN1FMosbbdr1uc7saNetCMO0UIUB-F-ihTgf_Q 728
wunderkafka/tests/__init__.py sha256=2Pob3xLevZcNgTtuetsfU0ieRxZEg8Zxq_m1ZtdNrjo 165
wunderkafka/tests/consumer.py sha256=5NjReB_9rnOqYE2H9QMuVryCeAyzy3UNkhG-p_D5nWw 1483
wunderkafka/tests/producer.py sha256=Kfe3SaOzl01UJ9Xrte44akRx08iRmTIIStOWQ76lXE4 899
wunderkafka/tests/schema_registry.py sha256=Aesbg1A-bZ4UTY-HSztax1oWPDKqhrEr2cFk8QRlRo0 942
wunderkafka-0.18.0.dist-info/LICENSE sha256=CeipvOyAZxBGUsFoaFqwkx54aPnIKEtm9a5u2uXxEws 10142
wunderkafka-0.18.0.dist-info/METADATA sha256=uWEoHZHYYw4x6eSX1j4N0AJVtDj13KtDC0VfIqEwpeY 7774
wunderkafka-0.18.0.dist-info/WHEEL sha256=OVMc5UfuAQiSplgO0_WdW7vXVGAt9Hdd6qtN4HotdyA 91
wunderkafka-0.18.0.dist-info/top_level.txt sha256=Mts8MmSZE5ITiQddna7-JdQ0XFrnoQWVe1n3k0AvzTk 12
wunderkafka-0.18.0.dist-info/RECORD

top_level.txt

wunderkafka