v0.5.39

What's Changed

• feat: type client args by @pepellsd in #2165
• docs: Added filtering technical information by @0xWEBMILK in #2161
• docs: access the msg attribute of BaseMiddleware by @geth-network in #2166
• docs: improve otel docs by @draincoder in #2167
• [FS-2158] Explicit error in case of mixed up fastapi.Depends and faststream.Depends by @NelsonNotes in #2160
• feat: raise exception at wrong router including by @bshelkhonov in #2172
• feat: extend asyncapi view for multiply subscribers by @Sehat1137 in #2174
• feat: add autoflush on kafka producer by @mdaffad in #2170
• feat: add RabbitMQ Channel object by @Lancetnik in #2171

New Contributors

• @geth-network made their first contribution in #2166
• @mdaffad made their first contribution in #2170

Full Changelog: 0.5.38...v0.5.39

v0.5.38

What's Changed

• Update Release Notes for 0.5.37 by @airt-release-notes-updater in #2140
• chore(deps): bump the pip group with 6 updates by @dependabot in #2144
• fix: pydantic211 compat by @Lancetnik in #2150
• Tweak RabbitMQ queue argument lists by @Arseniy-Popov in #2148
• fix: prevent duplicate logging handler registration when calling broker.start() by @banksemi in #2153
• chore(deps): bump the pip group with 5 updates by @dependabot in #2154
• Move to ag2ai organization by @davorrunje in #2156

New Contributors

• @banksemi made their first contribution in #2153

Full Changelog: 0.5.37...0.5.38

v0.5.37

What's Changed

• fix: correct Confluent options name mapping by @Lancetnik in #2137
• fix: correct call_decorators wrapping order by @Lancetnik in #2138

Full Changelog: 0.5.36...0.5.37

v0.5.36

What's Changed

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

New Contributors

• @NelsonNotes made their first contribution in #2097
• @diskream made their first contribution in #2098
• @MaximGit1 made their first contribution in #2112
• @MaestroXXXVIII made their first contribution in #2113
• @Sabfo made their first contribution in #2115
• @s-v-y-a-t made their first contribution in #2118
• @bshelkhonov made their first contribution in #2117
• @RenameMe1 made their first contribution in #2119
• @close2code-palm made their first contribution in #2123
• @TurtleOld made their first contribution in #2121
• @guitvcer made their first contribution in #2127
• @fadedDexofan made their first contribution in #2131

Full Changelog: 0.5.35...0.5.36

v0.5.35

What's Changed

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

New Contributors

• @Arseniy-Popov made their first contribution in #2017
• @Yakov-Varnaev made their first contribution in #2073
• @0xWEBMILK made their first contribution in #2080
• @Sandldan made their first contribution in #2081

Full Changelog: 0.5.34...0.5.35

v0.5.34

What's Changed

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

New Contributors

• @HybridBit made their first contribution in #1984
• @rishabhc32 made their first contribution in #1995
• @AlexPetul made their first contribution in #2009
• @MagicAbdel made their first contribution in #2011
• @herotomg made their first contribution in #2023

Full Changelog: 0.5.33...0.5.34

v0.5.33

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 #1963
• fix #1967: correct empty kafka message body processing by @Lancetnik in #1968

Full Changelog: 0.5.32...0.5.33

v0.5.32

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!

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 #1960
• Concurrent confluent kafka by @Flosckow in #1961
• fix: extend validation for --factory param by @Sehat1137 in #1964
• fix: support only uvicorn ASGI Runner by @Sehat1137 in #1965

Full Changelog: 0.5.31...0.5.32

v0.5.31

What's Changed

Well, you (community) made a new breathtaken release for us!
Thanks to all of this release contributors.

Special thanks to @Flosckow . He promotes a new perfect feature - concurrent Kafka subscriber (with autocommit mode)

from faststream.kafka 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 with his ASGI CLI start fixins - now you can use FastStream CLI to scale your AsgiFastStream application by workers

faststream run main:asgi --workers 2

There are a lot of other incredible changes you made:

• feat: add NatsMessage ack_sync method #1906 by @wpn10 in #1909
• feat: support running ASGI app with Uvicorn using file descriptor by @minhyeoky in #1923
• feat: Add kafka concurrent subscriber by @Flosckow in #1912
• fix: bug when using one register for several middleware by @roma-frolov in #1921
• fix: change oauth type in asyncapi schema by @spataphore1337 in #1926
• fix: HandlerException ignored by @roma-frolov in #1928
• fix: Pomo/nats router by @Drakorgaur in #1932
• fix: RabbitBroker's ping is more objective by @roma-frolov in #1933
• fix: AsyncAPI 2.6.0 fix empty channels for KafkaSubscriber and ConfluentSubscriber if partitions provided by @KrySeyt in #1930
• fix: #1874 support workers for ASGI FastStream by @Sehat1137 in #1936
• fix: correct middlewares order by @sheldygg in #1935
• chore: run PR altering automated check in same CI job by @kumaranvpl in #1942
• chore: pin typer version by @Lancetnik in #1947

New Contributors

• @wpn10 made their first contribution in #1909
• @minhyeoky made their first contribution in #1923

Full Changelog: 0.5.30...0.5.31

v0.5.30

What's Changed

• Introducing FastStream Guru on Gurubase.io by @kursataktas in #1903
• docs: add gurubase badge to the doc by @Lancetnik in #1905
• fix: allow users to pass nkeys_seed_str as argument for NATS broker. by @Drakorgaur in #1908
• Add more warning's to nats subscription factory by @sheldygg in #1907
• fix: correct working with dependencies versions by @Lancetnik in #1918

New Contributors

• @kursataktas made their first contribution in #1903
• @Drakorgaur made their first contribution in #1908

Full Changelog: 0.5.29...0.5.30