fastkafka

View on PyPIReverse Dependencies (0)

0.8.0 fastkafka-0.8.0-py3-none-any.whl

Wheel Details

Project: fastkafka
Version: 0.8.0
Filename: fastkafka-0.8.0-py3-none-any.whl
Download: [link]
Size: 106843
MD5: d89c4ca72496d100c7dffeacd5f330d8
SHA256: 7e39ef32c7e4bb534a7f907aaa3baad3b758779f374d43b39c3072ca4aada0fa
Uploaded: 2023-07-06 14:45:19 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: fastkafka
Version: 0.8.0
Summary: FastKafka is a powerful and easy-to-use Python library for building asynchronous web services that interact with Kafka topics. Built on top of FastAPI, Starlette, Pydantic, AIOKafka and AsyncAPI, FastKafka simplifies the process of writing producers and consumers for Kafka topics.
Author: airt
Author-Email: info[at]airt.ai
Home-Page: https://github.com/airtai/fastkafka
Project-Url: Bug Tracker, https://github.com/airtai/fastkafka/issues
Project-Url: CI, https://github.com/airtai/fastkafka/actions
Project-Url: Documentation, https://fastkafka.airt.ai/
Project-Url: Tutorial, https://colab.research.google.com/github/airtai/fastkafka/blob/main/nbs/guides/Guide_00_FastKafka_Demo.ipynb
License: Apache Software License 2.0
Keywords: nbdev jupyter notebook python kafka
Classifier: Development Status :: 5 - Production/Stable
Classifier: Intended Audience :: Developers
Classifier: Natural Language :: English
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: License :: OSI Approved :: Apache Software License
Requires-Python: >=3.8
Requires-Dist: aiokafka (>=0.8.0)
Requires-Dist: anyio (>=3.0)
Requires-Dist: asyncer (>=0.0.2)
Requires-Dist: docstring-parser (>=0.15)
Requires-Dist: nest-asyncio (>=1.5.6)
Requires-Dist: pydantic (>=2.0)
Requires-Dist: tqdm (>=4.62)
Requires-Dist: typer (>=0.7.0)
Requires-Dist: psutil (>=5.9.5); platform_system == "Windows"
Requires-Dist: fastavro (>=1.7.3); extra == "avro"
Requires-Dist: PyYAML (>=5.3.1); extra == "dev"
Requires-Dist: aiohttp (>=3.8.4); extra == "dev"
Requires-Dist: bandit (==1.7.5); extra == "dev"
Requires-Dist: black (==23.3.0); extra == "dev"
Requires-Dist: email-validator (>=2.0.0); extra == "dev"
Requires-Dist: fastapi (>=0.100.0b2); extra == "dev"
Requires-Dist: fastavro (>=1.7.3); extra == "dev"
Requires-Dist: install-jdk (==0.3.0); extra == "dev"
Requires-Dist: ipython (<8.13); extra == "dev"
Requires-Dist: ipywidgets (<=8.0.4,>=8.0); extra == "dev"
Requires-Dist: isort (==5.12.0); extra == "dev"
Requires-Dist: mypy (==1.3.0); extra == "dev"
Requires-Dist: nbconvert (>=7.2.9); extra == "dev"
Requires-Dist: nbdev-mkdocs (==0.6.0); extra == "dev"
Requires-Dist: nbformat (>=5.7.3); extra == "dev"
Requires-Dist: nbqa (==1.6.3); extra == "dev"
Requires-Dist: numpy (>=1.21.0); extra == "dev"
Requires-Dist: pandas (>=1.2.0); extra == "dev"
Requires-Dist: pre-commit (==3.3.1); extra == "dev"
Requires-Dist: pytest (==7.3.1); extra == "dev"
Requires-Dist: requests (>=2.20); extra == "dev"
Requires-Dist: scikit-learn (==1.2.1); extra == "dev"
Requires-Dist: semgrep (==1.21.0); extra == "dev"
Requires-Dist: uvicorn (==0.22.0); extra == "dev"
Requires-Dist: PyYAML (>=5.3.1); extra == "docs"
Requires-Dist: aiohttp (>=3.8.4); extra == "docs"
Requires-Dist: install-jdk (==0.3.0); extra == "test"
Requires-Dist: ipywidgets (<=8.0.4,>=8.0); extra == "test"
Requires-Dist: requests (>=2.20); extra == "test"
Provides-Extra: avro
Provides-Extra: dev
Provides-Extra: docs
Provides-Extra: test
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 23228 characters]

WHEEL

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

RECORD

Path Digest Size
fastkafka/__init__.py sha256=mSbv-qIgU8gLOUdqnK4j1RdTAX3NoYh4-eUNt39frNo 522
fastkafka/_aiokafka_imports.py sha256=F2JpDrrjmQVZcT2duzbKl0dgIyqfptRD1bTmk7b_1Xs 398
fastkafka/_cli.py sha256=PoJo5Xnq5VtlmRaeBoJCcZSss5njfNcnw5CA6WY43WM 2108
fastkafka/_cli_docs.py sha256=mJlbmTUpKP2QHaDYyUkModzCQCciUjxbHdFohphZCd0 5764
fastkafka/_cli_testing.py sha256=E1yJM_kUJGcZWzab8xNwRCFM0YV0clIt-kLD0aCAj5E 996
fastkafka/_docusaurus_helper.py sha256=UN60gkKp05VmSJ4jLfIDVuGCmFMBlLnup_wCW1OmVO4 32769
fastkafka/_helpers.py sha256=I1g8y_odcm0AfPHZq1fsVsz2wI9eqUc5FQovMMgaVgE 51560
fastkafka/_modidx.py sha256=p1eBsPmYvKeQqX2-kW3XdZuBl7H8JASwnS3APvyK5Rw 87787
fastkafka/_server.py sha256=QrZsts4FlTcyJT6la25ZruEYu8OhZ9QtaQF_HKxmhAg 7313
fastkafka/encoder.py sha256=1_fIQs4Ff0hEd7qpvYneelzz6OmSt6GTgRnFw4WtkzQ 598
fastkafka/executors.py sha256=D8-HCKZgq2_vm-LKa9oiZYzt6e9_unpJheYEZuXunRY 454
fastkafka/testing.py sha256=lcKwP7jzUDJEtKWtUAV-iCFfaa5AdotEO7bxzhUh26U 858
fastkafka/_application/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
fastkafka/_application/app.py sha256=qLMQ3OC2bV6Us9CTDSNHVa082BKXHdyVr9b9JUm-0G4 40048
fastkafka/_application/tester.py sha256=wXAsQdKP9JxhU2kKd2NY3heY77aq5Fl0N5VVS0x6-1A 13467
fastkafka/_components/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
fastkafka/_components/_subprocess.py sha256=F5C5nXuehfx5uRQ3A3_GX_jOftLcr7qMg3FE1XkTzqk 4981
fastkafka/_components/aiokafka_consumer_loop.py sha256=EFc478nFEXJIQusLKovZQ2KgDJHfAk5OEE4sY0-cZG8 13623
fastkafka/_components/asyncapi.py sha256=-Xf18hXNODx1NqVcI-ib8f1aYslZZAB1AkvvCJGzyhI 19082
fastkafka/_components/benchmarking.py sha256=YLNuMKKaDE35rWMRG1wmvdHxUcapTrHHpcRnOSxm82M 2905
fastkafka/_components/docs_dependencies.py sha256=6gVZzflH9ZXeLUjH7VQ4JWnz4O8oQTWmQvAqqdH1FaE 6991
fastkafka/_components/helpers.py sha256=cLcgSCA-wqMOfRTwoKXp3cF3WxAWJjJ72gFFQZHcbpQ 4136
fastkafka/_components/logger.py sha256=RbnEEHlSIv3qta81lxvtAdfmuhlp-RUgWghLnuAud34 4730
fastkafka/_components/meta.py sha256=yua7qV3OalFjTJwsHCPveT84oHsKOrPye9TPDr_D6ZI 13150
fastkafka/_components/producer_decorator.py sha256=FxFEnGOhftjqafEJ4UqgqnLFYZj5EshJ02rUtViI3qk 8102
fastkafka/_components/task_streaming.py sha256=7pYtnvy57NODhK0iGMzo6-0ZSexqxKzh9zavpJCrRKw 11893
fastkafka/_components/test_dependencies.py sha256=ZpK4pKisLiO5TLGhn5UL_WGRfCfQ52ziHwI9yYl1LDU 10312
fastkafka/_components/encoder/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
fastkafka/_components/encoder/avro.py sha256=X-SW_N8YVsk2f5VIDFTHj2qEbyu3xezjOtbvuooZefM 15024
fastkafka/_components/encoder/json.py sha256=ctsgdw8yaJt9cSMnNHlmC0HI_V_iPHdelx84ugj8Gp8 1612
fastkafka/_testing/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
fastkafka/_testing/apache_kafka_broker.py sha256=jm46lDHznrRgjlmPb42oEozV0KnLs1NusNsZNQ9HlUM 27911
fastkafka/_testing/in_memory_broker.py sha256=e71xMl_TMrByVeXhbxdzbBjOX9OBi2G4htwryt_H2uw 28557
fastkafka/_testing/local_redpanda_broker.py sha256=IgPPmg4Abt3nBDO0RbLVCYhPE-NWdSHe7Ej8j0iwjZs 13966
fastkafka/_testing/test_utils.py sha256=D0NGkAu-jNIog5qy2Pft1txhq3e5aq-6nHSygD3ccns 5428
fastkafka-0.8.0.dist-info/LICENSE sha256=xx0jnfkXJvxRnG63LTGOxlggYnIysveWIZ6H3PNdCrQ 11357
fastkafka-0.8.0.dist-info/METADATA sha256=dw4Ufp6WwHxPobK7YztNVfZewqUrjPeRdo06HMz_XmI 26581
fastkafka-0.8.0.dist-info/WHEEL sha256=G16H4A3IeoQmnOrYV4ueZGKSjhipXx8zc8nu9FGlvMA 92
fastkafka-0.8.0.dist-info/entry_points.txt sha256=rmyENlIg2hzwTF1lajiVQCwJhpcaD8TPCirN9_Zbwtc 146
fastkafka-0.8.0.dist-info/top_level.txt sha256=rpIad1yXPkwQFLVw896PWioiXctGJk-ap-rmtqlwDsI 10
fastkafka-0.8.0.dist-info/RECORD

top_level.txt

fastkafka

entry_points.txt

fastkafka = fastkafka._cli:_app
run_fastkafka_server_process = fastkafka._server:_app
[nbdev]
fastkafka = fastkafka._modidx:d