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