airflow-provider-kafka

View on PyPIReverse Dependencies (0)

0.2.2 airflow_provider_kafka-0.2.2-py3-none-any.whl

Wheel Details

Project: airflow-provider-kafka
Version: 0.2.2
Filename: airflow_provider_kafka-0.2.2-py3-none-any.whl
Download: [link]
Size: 20557
MD5: 120cc0604b7584024f62285d9248e8d7
SHA256: e48d7d9946368578a24a4ba2f0b103f30167d447e98f51d5dcdd5e3e2e3fab53
Uploaded: 2023-02-03 20:58:08 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: airflow-provider-kafka
Version: 0.2.2
Summary: Apache Airflow Kafka provider containing Deferrable Operators & Sensors.
Author: Dylan Storey
Author-Email: dylan.storey[at]astronomer.io
Home-Page: https://github.com/astronomer/airflow-provider-kafka
Project-Url: Source Code, https://github.com/astronomer/airflow-provider-kafka
Project-Url: Homepage, https://github.com/astronomer/airflow-provider-kafka
Project-Url: Changelog, https://github.com/astronomer/airflow-provider-kafka/blob/main/CHANGELOG.md
License: Apache License 2.0
Classifier: Environment :: Web Environment
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Requires-Python: >=3.7
Requires-Dist: apache-airflow (>=2.2.0)
Requires-Dist: asgiref
Requires-Dist: confluent-kafka (>=1.8.2)
Requires-Dist: mypy (>=0.800); extra == "dev"
Requires-Dist: pytest; extra == "dev"
Requires-Dist: pre-commit; extra == "dev"
Provides-Extra: dev
Description-Content-Type: text/markdown
License-File: LICENSE.txt
[Description omitted; length: 3315 characters]

WHEEL

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

RECORD

Path Digest Size
airflow_provider_kafka/__init__.py sha256=X0D9vj79AlXn5QfyOlKC87PLD6PCJHWvoH4FIMFhT3E 592
airflow_provider_kafka/shared_utils.py sha256=0bT8YM__D43OQ81XugbG8ZTATfWTNwJ9a8CpJyVYqs8 1189
airflow_provider_kafka/hooks/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
airflow_provider_kafka/hooks/admin_client.py sha256=3Pqns6M6-S5w9H1JjLy-YSZuagFrnofbeejJIIm7M-w 2596
airflow_provider_kafka/hooks/consumer.py sha256=1XcLkbXq714xb-NFOt7_QNX0lbLihckkwkdZiqENs08 2021
airflow_provider_kafka/hooks/producer.py sha256=_lF3a6Vw4KMjSv-jUmy8-qZgy7vCH7kPrrJatO9DQ2g 2078
airflow_provider_kafka/operators/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
airflow_provider_kafka/operators/await_message.py sha256=v2qO_ykstD1lXUvgOMNOOcccSHRvA2F3nORVuHxxFYE 4221
airflow_provider_kafka/operators/consume_from_topic.py sha256=u383vdvAUqhQ_HZvqQX0fz3WCtl9YoeRgVqyPnBUTjw 7904
airflow_provider_kafka/operators/event_triggers_function.py sha256=Q1GR-du9JjGJjxpEYJsYB-6SX-zpJcPKhSF_YtCmphA 5100
airflow_provider_kafka/operators/produce_to_topic.py sha256=Z7iCSszJ9yuzuxFERcqggvuuRmgxAmv-Letuh6Te15U 4911
airflow_provider_kafka/triggers/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
airflow_provider_kafka/triggers/await_message.py sha256=FDEIsjfphAKsZb-aG-ebC_e-ApLVY1JJpdCnWnjyQL8 4932
airflow_provider_kafka-0.2.2.dist-info/LICENSE.txt sha256=QwcOLU5TJoTeUhuIXzhdCEEDDvorGiC6-3YTOl4TecE 11356
airflow_provider_kafka-0.2.2.dist-info/METADATA sha256=tDUPUp_Nn4ZET-XMEmuvYR4hRcI9a4c1NowmJbXepW4 4671
airflow_provider_kafka-0.2.2.dist-info/WHEEL sha256=2wepM1nk4DS4eFpYrW1TTqPcoGNfHhhO_i5m4cOimbo 92
airflow_provider_kafka-0.2.2.dist-info/top_level.txt sha256=3sQ33AxbwIGHW-eL5r4OMC5aL6UO1V9y4hp0uogmekI 23
airflow_provider_kafka-0.2.2.dist-info/RECORD

top_level.txt

airflow_provider_kafka