ag2ai/faststream 0.5.32

v0.5.32

on GitHub

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