Faststream

What's Changed

* fix: correct Confluent options name mapping by Lancetnik in https://github.com/airtai/faststream/pull/2137
* fix: correct call_decorators wrapping order by Lancetnik in https://github.com/airtai/faststream/pull/2138

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.36...0.5.37

What's Changed

* fix 2088: respect parsed sasl_mechanism by Lancetnik in https://github.com/airtai/faststream/pull/2092
* Add delay to unassigned consumer warning by Arseniy-Popov in https://github.com/airtai/faststream/pull/2090
* fix: resolve forward refs in FastAPI integration by Lancetnik in https://github.com/airtai/faststream/pull/2096
* fix: unwrap handler function when getting dependant by Yakov-Varnaev in https://github.com/airtai/faststream/pull/2093
* fix: make `CriticalLogMiddleware` respect broker log level (2130) by fadedDexofan in https://github.com/airtai/faststream/pull/2131
* Fixed nested dataclasses schema generation by NelsonNotes in https://github.com/airtai/faststream/pull/2097
* refactoring ConfluentConfig by diskream in https://github.com/airtai/faststream/pull/2098
* refactored subscription Annotation Serialization by MaximGit1 in https://github.com/airtai/faststream/pull/2112
* docs: added pros and cons to publishers page by 0xWEBMILK in https://github.com/airtai/faststream/pull/2103
* docs: follow off logging recommendations by guitvcer in https://github.com/airtai/faststream/pull/2127
* docs: add example for probes by Sehat1137 in https://github.com/airtai/faststream/pull/2108
* docs: fix footer after gurubase intagration by Rusich90 in https://github.com/airtai/faststream/pull/2120
* docs: Toggle Gurubase widget theme by bshelkhonov in https://github.com/airtai/faststream/pull/2117
* docs(2109): Inlines the include files directly into the location where it is used(faststream.md, scheduling.md) by MaestroXXXVIII in https://github.com/airtai/faststream/pull/2113
* docs(2109): "getting-started/subscription" section has been updated by MaximGit1 in https://github.com/airtai/faststream/pull/2114
* docs(2109): make PR reference by Lancetnik in https://github.com/airtai/faststream/pull/2111
* docs(2109): inline includes getting-started/lifespan by Sabfo in https://github.com/airtai/faststream/pull/2115
* docs(2109): inline includes getting-started/dependencies by Sabfo in https://github.com/airtai/faststream/pull/2116
* docs(2109): inline includes getting-started/serialization/decoder.md by s-v-y-a-t in https://github.com/airtai/faststream/pull/2118
* docs(2109): deleted include code in getting_started/index by RenameMe1 in https://github.com/airtai/faststream/pull/2119
* docs(2109): Docs/include inline by close2code-palm in https://github.com/airtai/faststream/pull/2123
* docs(2109): deleted include code in getting_started/opentelemetry by RenameMe1 in https://github.com/airtai/faststream/pull/2125
* docs(2109): deleted include code in getting_started/prometheus by RenameMe1 in https://github.com/airtai/faststream/pull/2124
* docs(2109): inline includes getting-started/integrations by TurtleOld in https://github.com/airtai/faststream/pull/2121
* docs(2109): remove docs includes context, serialization, publishing by TurtleOld in https://github.com/airtai/faststream/pull/2126

New Contributors
* NelsonNotes made their first contribution in https://github.com/airtai/faststream/pull/2097
* diskream made their first contribution in https://github.com/airtai/faststream/pull/2098
* MaximGit1 made their first contribution in https://github.com/airtai/faststream/pull/2112
* MaestroXXXVIII made their first contribution in https://github.com/airtai/faststream/pull/2113
* Sabfo made their first contribution in https://github.com/airtai/faststream/pull/2115
* s-v-y-a-t made their first contribution in https://github.com/airtai/faststream/pull/2118
* bshelkhonov made their first contribution in https://github.com/airtai/faststream/pull/2117
* RenameMe1 made their first contribution in https://github.com/airtai/faststream/pull/2119
* close2code-palm made their first contribution in https://github.com/airtai/faststream/pull/2123
* TurtleOld made their first contribution in https://github.com/airtai/faststream/pull/2121
* guitvcer made their first contribution in https://github.com/airtai/faststream/pull/2127
* fadedDexofan made their first contribution in https://github.com/airtai/faststream/pull/2131

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.35...0.5.36

What's Changed

* Add concurrent-between-partitions kafka subscriber by Arseniy-Popov in https://github.com/airtai/faststream/pull/2017
* chore: make uv sync working by Lancetnik in https://github.com/airtai/faststream/pull/2041
* docs: add Ask AI button with Gurubase widget by Lancetnik in https://github.com/airtai/faststream/pull/2042
* docs: create FastStream image shield by Lancetnik in https://github.com/airtai/faststream/pull/2062
* Close 2060 by Flosckow in https://github.com/airtai/faststream/pull/2063
* feat: allow broker setting in on_startup hook by Yakov-Varnaev in https://github.com/airtai/faststream/pull/2073
* ImportError raises change by 0xWEBMILK in https://github.com/airtai/faststream/pull/2080
* docs: Fix distributed spelling error in task scheduling page by Sandldan in https://github.com/airtai/faststream/pull/2081
* Exclude confluent-kafka 2.8.1 by Yakov-Varnaev in https://github.com/airtai/faststream/pull/2084

New Contributors
* Arseniy-Popov made their first contribution in https://github.com/airtai/faststream/pull/2017
* Yakov-Varnaev made their first contribution in https://github.com/airtai/faststream/pull/2073
* 0xWEBMILK made their first contribution in https://github.com/airtai/faststream/pull/2080
* Sandldan made their first contribution in https://github.com/airtai/faststream/pull/2081

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.34...0.5.35

What's Changed

* fix: when / present in virtual host name and passing as uri by pepellsd in https://github.com/airtai/faststream/pull/1979
* fix (2013): allow to create publisher in already connected broker by Lancetnik in https://github.com/airtai/faststream/pull/2024
* feat: add BatchBufferOverflowException by spataphore1337 in https://github.com/airtai/faststream/pull/1990
* feat: add static instrumentation info by draincoder in https://github.com/airtai/faststream/pull/1996
* docs: remove reference of "faststream.access" by rishabhc32 in https://github.com/airtai/faststream/pull/1995
* docs: fixed typo in publishing/test.md by AlexPetul in https://github.com/airtai/faststream/pull/2009
* docs: ability to declare queue/exchange binding by MagicAbdel in https://github.com/airtai/faststream/pull/2011
* docs: fix spelling mistake of `/health` by herotomg in https://github.com/airtai/faststream/pull/2023
* docs: update aio-pika external docs URL as it has been moved by HybridBit in https://github.com/airtai/faststream/pull/1984
* refactor: add type annotations for RabbitQueue and enum for queue type by pepellsd in https://github.com/airtai/faststream/pull/2002

New Contributors
* HybridBit made their first contribution in https://github.com/airtai/faststream/pull/1984
* rishabhc32 made their first contribution in https://github.com/airtai/faststream/pull/1995
* AlexPetul made their first contribution in https://github.com/airtai/faststream/pull/2009
* MagicAbdel made their first contribution in https://github.com/airtai/faststream/pull/2011
* herotomg made their first contribution in https://github.com/airtai/faststream/pull/2023

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.33...0.5.34

What's Changed

Just a Confluent & Kafka hotfix. Messages without body (with key only) parsing correctly now.

* fix: Confluent, read messages under lock by Lancetnik in https://github.com/airtai/faststream/pull/1963
* fix 1967: correct empty kafka message body processing by Lancetnik in https://github.com/airtai/faststream/pull/1968

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.32...0.5.33

What's Changed

Thanks to Flosckow one more time for a new release! Now you have an ability to consume Confluent messages (in autocommit mode) concurrently!

python
from faststream.confluent import KafkaBroker

broker = KafkaBroker()

broker.subscriber("topic", max_workers=10)
async def handler():
"""Using `max_workers` option you can process up to 10 messages by one subscriber concurrently"""


Also, thanks to Sehat1137 for his ASGI CLI support bugfixes

* fix 1959: propagate logger to Confluent by Lancetnik in https://github.com/airtai/faststream/pull/1960
* Concurrent confluent kafka by Flosckow in https://github.com/airtai/faststream/pull/1961
* fix: extend validation for --factory param by Sehat1137 in https://github.com/airtai/faststream/pull/1964
* fix: support only uvicorn ASGI Runner by Sehat1137 in https://github.com/airtai/faststream/pull/1965

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.31...0.5.32