Skip to main content

Apache Kafka support for the Ampel system.

Project description

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 metadata

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

ampel_kafka-0.10.0a0.tar.gz (8.8 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

ampel_kafka-0.10.0a0-py3-none-any.whl (14.0 kB view details)

Uploaded Python 3

File details

Details for the file ampel_kafka-0.10.0a0.tar.gz.

File metadata

  • Download URL: ampel_kafka-0.10.0a0.tar.gz
  • Upload date:
  • Size: 8.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.14

File hashes

Hashes for ampel_kafka-0.10.0a0.tar.gz
Algorithm Hash digest
SHA256 5487a8545ca85155248b1b1d590ded34e2169125d1e1608f69abd8743210fb95
MD5 72716a0b773a4f0eb827215c9772e525
BLAKE2b-256 d26f724a64ead8e2683bee48b6caedc84a00da6dde9139cdc7701cee7b8d62c0

See more details on using hashes here.

Provenance

The following attestation bundles were made for ampel_kafka-0.10.0a0.tar.gz:

Publisher: main.yml on AmpelAstro/Ampel-kafka

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file ampel_kafka-0.10.0a0-py3-none-any.whl.

File metadata

  • Download URL: ampel_kafka-0.10.0a0-py3-none-any.whl
  • Upload date:
  • Size: 14.0 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.14

File hashes

Hashes for ampel_kafka-0.10.0a0-py3-none-any.whl
Algorithm Hash digest
SHA256 85e3429b8495b31042285142c884a645eea1c9199e04fcf600b38323c1fa5694
MD5 fd589702194e0ec55a85ec57f3399335
BLAKE2b-256 5bc9987066fd85610a845db5d4ab04b710b157c9210407530e60564cac13732a

See more details on using hashes here.

Provenance

The following attestation bundles were made for ampel_kafka-0.10.0a0-py3-none-any.whl:

Publisher: main.yml on AmpelAstro/Ampel-kafka

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page