Metadata-Version: 2.4
Name: ampel-kafka
Version: 0.10.0a0
Summary: Apache Kafka support for the Ampel system.
License-Expression: BSD-3-Clause
Author: Jakob van Santen
Author-email: jakob.van.santen@desy.de
Maintainer: Jakob van Santen
Maintainer-email: jakob.van.santen@desy.de
Requires-Python: >=3.11, <4
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Science/Research
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Programming Language :: Python :: 3.14
Classifier: Topic :: Scientific/Engineering :: Information Analysis
Classifier: Topic :: Scientific/Engineering :: Astronomy
Classifier: Typing :: Typed
Provides-Extra: hop
Requires-Dist: ampel-alerts (>=0.10.3,<0.11.0)
Requires-Dist: ampel-core (>=0.10.6a23,<0.11)
Requires-Dist: ampel-interface (>=0.10.4.post2,<0.11)
Requires-Dist: confluent-kafka[schemaregistry] (>=2.15.0,<3.0.0)
Requires-Dist: fastavro (>=1.12.2,<2.0.0)
Requires-Dist: hop-client (>=0.12.1,<0.13.0) ; extra == "hop"
Requires-Dist: py-avro-schema (>=3.8.2,<4.0.0) ; extra == "hop"
Requires-Dist: requests (>=2.34.2,<3.0.0)
Project-URL: Homepage, https://ampelproject.github.io
Project-URL: Repository, https://github.com/AmpelAstro/Ampel-kafka
Description-Content-Type: text/markdown

# Ampel-kafka

Apache Kafka support for the Ampel system.

## Units

* **KafkaAlertLoader**: load alerts from a Kafka topic
* **KafkaProducer**: produce bundles of stock/t0/t1/t2 docs to a topic
* **KafkaConsumer**: consume bundles of stock/t0/t1/t2 docs from a topic
* **KafkaAdapter**: produce UnitResult body to a Kafka topic

### Optional `hop`

* **HopskotchAdapter**: produce UnitResult body to a Kafka topic with [Hopskotch](https://scimma.org/hopskotch) metadata

