Metadata-Version: 2.4
Name: omnixys-kafka
Version: 2.0.3
Summary: Omnixys shared Kafka package (producer, consumer with retry/DLQ/idempotency/circuit-breaker)
Project-URL: Homepage, https://github.com/omnixys/omnixys
Project-URL: Repository, https://github.com/omnixys/omnixys
Author-email: Omnixys Team <team@omnixys.com>
License: GPL-3.0-or-later
Keywords: async,event-driven,kafka,microservices,omnixys
Classifier: Development Status :: 4 - Beta
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: GNU General Public License v3 or later (GPLv3+)
Classifier: Programming Language :: Python :: 3.14
Classifier: Typing :: Typed
Requires-Python: >=3.14
Requires-Dist: aiokafka>=0.14.0
Requires-Dist: opentelemetry-api>=1.42.1
Requires-Dist: opentelemetry-instrumentation-aiokafka>=0.63b1
Requires-Dist: opentelemetry-sdk>=1.42.1
Description-Content-Type: text/markdown

# omnixys-kafka

Omnixys shared Kafka package with producer, consumer, retry, DLQ, idempotency, and circuit-breaker.

## Installation

```bash
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

```python
from omnixys_kafka import AIOKafkaEventProducer, KafkaConsumer, JsonEventSerializer
```

## License

GPL-3.0-or-later
