Metadata-Version: 2.4
Name: neonlink-client
Version: 0.3.7
Summary: NeonLink SDK — Kafka/Redpanda client + Protocol Buffer definitions for Python
Author-email: LetA-Tech <dev@leta.tech>
License-Expression: MIT
Project-URL: Homepage, https://github.com/LetA-Tech/mcfo-neonlink
Project-URL: Repository, https://github.com/LetA-Tech/mcfo-neonlink
Requires-Python: >=3.11
Description-Content-Type: text/markdown
Requires-Dist: confluent-kafka>=2.13.0
Requires-Dist: protobuf>=4.24.0
Provides-Extra: tracing
Requires-Dist: opentelemetry-api>=1.20.0; extra == "tracing"
Provides-Extra: structlog
Requires-Dist: structlog>=24.1.0; extra == "structlog"
Provides-Extra: observability
Requires-Dist: opentelemetry-api>=1.20.0; extra == "observability"
Requires-Dist: structlog>=24.1.0; extra == "observability"
Provides-Extra: dev
Requires-Dist: pytest>=7.0; extra == "dev"

# neonlink-client

NeonLink SDK for Python — Kafka/Redpanda client + Protocol Buffer definitions.

## Installation

```bash
pip install neonlink-client
```

## Usage

### Kafka SDK

```python
from neonlink import Producer, Consumer, Config

config = Config.from_env()  # reads NEONLINK_* env vars
producer = Producer(config)
consumer = Consumer(config, group_id="my-service")
```

### Proto Types

```python
from messaging.v1 import messaging_pb2

header = messaging_pb2.MessageHeader(
    message_id="uuid",
    correlation_id="correlation-uuid",
    message_type=messaging_pb2.MESSAGE_TYPE_ETL_COMPLETION,
)
```

## Package Contents

- `neonlink` — Kafka/Redpanda client SDK (Producer, Consumer, circuit breaker, DLQ, tracing)
- `messaging.v1` — Protocol Buffer definitions for inter-service messaging

## Source

Published from [mcfo-neonlink](https://github.com/LetA-Tech/mcfo-neonlink).
