faststream
faststream copied to clipboard
airtai
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
# Description 1. Feature: Add `from faststream.rabbit.annotations import Connection, Channel` shortcuts 2. Bugfix: RabbitMQ RabbitRouter prefix now affects to queue routing key as well 3. Feature (close #1402): add `broker.add_middleware`...
I am integrating my faststream app with senty. For realizing end-to-end tracing between multiple faststream apps i need receive the trace_id from headers of certain message in kafka. In Perfect...
**Describe the bug** Retries do not work for the confluent-kafka library as far as I can tell. Seems related to https://github.com/airtai/faststream/issues/1001 in some way. **How to reproduce** Include source code:...
To suggest an idea or inquire about a new Message Broker supporting feature or any other enhancement, please follow this template: **Is your feature request related to a problem? Please...
# Description Created `TelemetryMiddleware` with support for `OpenTelemetry` traces and metrics. - Support for distributed traces - Corresponds to SemConv for messaging spans Fixes #916 ## Type of change -...
We should create a special class to make users able to setup outgoing message metainformation in `@publihser` decorator case ```python @broker.publisher("out") @broker.subscriber("in") async def handler(msg) -> Reponse: return Reponse(data=b"", headers={})...
We must be able to produce to broker_2 while consuming from broker_1
This has been failing for a month. It started happening after a specific point - https://github.com/airtai/faststream/actions/workflows/check-broken-links-in-docs.yaml
**Describe the bug** When performing an RPC call with a `TestRabbitBroker` where the subscriber returns a pydantic model, the response type is different depending on whether the test runs with...
Also we should update documentation accordingly