omnixys-kafka
Omnixys shared Kafka package with producer, consumer, retry, DLQ, idempotency, and circuit-breaker.
Installation
pip install omnixys-kafka
Features
- Async Kafka producer and consumer
- Built-in retry mechanisms
- Dead Letter Queue (DLQ) support
- Idempotency service
- Circuit breaker pattern
- OpenTelemetry instrumentation
Usage
from omnixys_kafka import AIOKafkaEventProducer, KafkaConsumer, JsonEventSerializer
License
GPL-3.0-or-later
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
omnixys_kafka-2.0.3.tar.gz
(26.8 kB
view details)
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file omnixys_kafka-2.0.3.tar.gz.
File metadata
- Download URL: omnixys_kafka-2.0.3.tar.gz
- Upload date:
- Size: 26.8 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.31 {"installer":{"name":"uv","version":"0.11.31","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
8113eb36e1cf2a43ba5394166c42cc8a5b1585f1e9eea1a2dd35c4dc873be3fd
|
|
| MD5 |
8b6f9cd48c1b14a6c095cb8fd431cb9c
|
|
| BLAKE2b-256 |
279789bee67a2498f621e48d241b152bdb70ef7fa7e2af89c411e84fad8508f2
|
File details
Details for the file omnixys_kafka-2.0.3-py3-none-any.whl.
File metadata
- Download URL: omnixys_kafka-2.0.3-py3-none-any.whl
- Upload date:
- Size: 8.0 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.31 {"installer":{"name":"uv","version":"0.11.31","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
8d1a499ec60f70e3e11bb7fa2f940e76acbb25777d736f7929ed335a9cecfd16
|
|
| MD5 |
265261abc6baeb344c16df391d18cb97
|
|
| BLAKE2b-256 |
d113f61fb6facbe87ed7abbd331ce4f122ecf0d385ad47788b57af42e3f21b00
|
