Faststream

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

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)

python
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

bash
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 https://github.com/airtai/faststream/pull/1909
* feat: support running ASGI app with Uvicorn using file descriptor by minhyeoky in https://github.com/airtai/faststream/pull/1923
* feat: Add kafka concurrent subscriber by Flosckow in https://github.com/airtai/faststream/pull/1912
* fix: bug when using one register for several middleware by roma-frolov in https://github.com/airtai/faststream/pull/1921
* fix: change oauth type in asyncapi schema by spataphore1337 in https://github.com/airtai/faststream/pull/1926
* fix: HandlerException ignored by roma-frolov in https://github.com/airtai/faststream/pull/1928
* fix: Pomo/nats router by Drakorgaur in https://github.com/airtai/faststream/pull/1932
* fix: RabbitBroker's ping is more objective by roma-frolov in https://github.com/airtai/faststream/pull/1933
* fix: AsyncAPI 2.6.0 fix empty channels for KafkaSubscriber and ConfluentSubscriber if partitions provided by KrySeyt in https://github.com/airtai/faststream/pull/1930
* fix: 1874 support workers for ASGI FastStream by Sehat1137 in https://github.com/airtai/faststream/pull/1936
* fix: correct middlewares order by sheldygg in https://github.com/airtai/faststream/pull/1935
* chore: run PR altering automated check in same CI job by kumaranvpl in https://github.com/airtai/faststream/pull/1942
* chore: pin typer version by Lancetnik in https://github.com/airtai/faststream/pull/1947

New Contributors

* wpn10 made their first contribution in https://github.com/airtai/faststream/pull/1909
* minhyeoky made their first contribution in https://github.com/airtai/faststream/pull/1923

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

What's Changed
* Introducing FastStream Guru on Gurubase.io by kursataktas in https://github.com/airtai/faststream/pull/1903
* docs: add gurubase badge to the doc by Lancetnik in https://github.com/airtai/faststream/pull/1905
* fix: allow users to pass `nkeys_seed_str` as argument for NATS broker. by Drakorgaur in https://github.com/airtai/faststream/pull/1908
* Add more warning's to nats subscription factory by sheldygg in https://github.com/airtai/faststream/pull/1907
* fix: correct working with dependencies versions by Lancetnik in https://github.com/airtai/faststream/pull/1918

New Contributors
* kursataktas made their first contribution in https://github.com/airtai/faststream/pull/1903
* Drakorgaur made their first contribution in https://github.com/airtai/faststream/pull/1908

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.29...0.5.30