Faststream

What's Changed

Finally, FastStream supports [OpenTelemetry](https://opentelemetry.io/) in a native way to collect the full trace of your services! Big thanks for draincoder for that!

First of all you need to install required dependencies to support OpenTelemetry:

bash
pip install faststream[otel]


Then you can just add a middleware for your broker and that's it!

python
from faststream import FastStream
from faststream.nats import NatsBroker
from faststream.nats.opentelemetry import NatsTelemetryMiddleware

broker = NatsBroker(
middlewares=(
NatsTelemetryMiddleware(),
)
)
app = FastStream(broker)


To find detailt information just visit our documentation aboout [telemetry](https://faststream.airt.ai/latest/getting-started/opentelemetry/)

P.S. The release includes basic OpenTelemetry support - messages tracing & basic metrics. Baggage support and correct spans linking in batch processing case will be added soon.

* fix: serialize TestClient rpc output to mock the real message by Lancetnik in https://github.com/airtai/faststream/pull/1452
* feature (916): Observability by draincoder in https://github.com/airtai/faststream/pull/1398

New Contributors
* draincoder made their first contribution in https://github.com/airtai/faststream/pull/1398

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.6...0.5.7

What's Changed

* feature: add --factory param by Sehat1137 in https://github.com/airtai/faststream/pull/1440
* feat: add RMQ channels options, support for prefix for routing_key, a… by Lancetnik in https://github.com/airtai/faststream/pull/1448
* feature: Add `from faststream.rabbit.annotations import Connection, Channel` shortcuts
* Bugfix: RabbitMQ RabbitRouter prefix now affects to queue routing key as well
* Feature (close 1402): add `broker.add_middleware` public API to append a middleware to already created broker
* Feature: add `RabbitBroker(channel_number: int, publisher_confirms: bool, on_return_raises: bool)` options to setup channel settings
* Feature (close 1447): add `StreamMessage.batch_headers` attribute to provide with access to whole batch messages headers

New Contributors

* Sehat1137 made their first contribution in https://github.com/airtai/faststream/pull/1440

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.5...0.5.6

What's Changed

Add support for explicit partition assignment in aiokafka `KafkaBroker` (special thanks to spataphore1337):

python
from faststream import FastStream
from faststream.kafka import KafkaBroker, TopicPartition

broker = KafkaBroker()

topic_partition_fisrt = TopicPartition("my_topic", 1)
topic_partition_second = TopicPartition("my_topic", 2)

broker.subscribe(partitions=[topic_partition_fisrt, topic_partition_second])
async def some_consumer(msg):
...


* Update Release Notes for 0.5.4 by faststream-release-notes-updater in https://github.com/airtai/faststream/pull/1421
* feature: manual partition assignment to Kafka by spataphore1337 in https://github.com/airtai/faststream/pull/1422
* Chore/update deps by Lancetnik in https://github.com/airtai/faststream/pull/1429
* Fix/correct dynamic subscriber registration by Lancetnik in https://github.com/airtai/faststream/pull/1433
* chore: bump version by Lancetnik in https://github.com/airtai/faststream/pull/1435


**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.4...0.5.5

What's Changed

* Update Release Notes for 0.5.3 by faststream-release-notes-updater in https://github.com/airtai/faststream/pull/1400
* fix (1415): raise SetupError if rpc and reply_to are using in TestCL… by Lancetnik in https://github.com/airtai/faststream/pull/1419
* Chore/update deps2 by Lancetnik in https://github.com/airtai/faststream/pull/1418
* refactor: correct security with kwarg params merging by Lancetnik in https://github.com/airtai/faststream/pull/1417
* fix (1414): correct Messag.ack error processing by Lancetnik in https://github.com/airtai/faststream/pull/1420

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.3...0.5.4

What's Changed
* Update Release Notes for 0.5.2 by faststream-release-notes-updater in https://github.com/airtai/faststream/pull/1382
* Fix/setup at broker connection instead of starting by Lancetnik in https://github.com/airtai/faststream/pull/1385
* Tests/add path tests by Lancetnik in https://github.com/airtai/faststream/pull/1388
* Fix/path with router prefix by Lancetnik in https://github.com/airtai/faststream/pull/1395
* chore: update dependencies by Lancetnik in https://github.com/airtai/faststream/pull/1396
* chore: bump version by Lancetnik in https://github.com/airtai/faststream/pull/1397
* chore: polishing by davorrunje in https://github.com/airtai/faststream/pull/1399


**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.2...0.5.3

What's Changed

Just a little bugfix patch. Fixes 1379 and 1376.

* Update Release Notes for 0.5.1 by faststream-release-notes-updater in https://github.com/airtai/faststream/pull/1378
* Tests/fastapi background by Lancetnik in https://github.com/airtai/faststream/pull/1380
* Fix/0.5.2 by Lancetnik in https://github.com/airtai/faststream/pull/1381


**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.1...0.5.2