ag2ai/faststream 0.5.1

v0.5.1

on GitHub

What's Changed

We already have some fixes related to RedisBroker (#1375, #1376) and some new features for you:

1. Now broke.include_router(...) allows to pass some arguments to setup router at including moment instead of creation

broker.include_router(
   router,
   prefix="test_",
   dependencies=[Depends(...)],
   middlewares=[BrokerMiddleware],
   include_in_schema=False,
)

1. KafkaBroker().subscriber(...) now consumes aiokafka.ConsumerRebalanceListener object.
   You can find more information about it in the official aiokafka doc

(close #1319)

broker = KafkaBroker()

broker.subscriber(..., listener=MyRebalancer())

pattern option was added too, but it is still experimental and does not support Path

1. Path feature perfomance was increased. Also, Path is suitable for NATS PullSub batch subscribtion as well now.

from faststream import NatsBroker, PullSub

broker = NastBroker()

@broker.subscriber(
    "logs.{level}",
    steam="test-stream",
    pull_sub=PullSub(batch=True),
)
async def base_handler(
    ...,
    level: str = Path(),
):
  ...

• Update Release Notes for 0.5.0 by @faststream-release-notes-updater in #1366
• chore: bump version by @Lancetnik in #1372
• feat: kafka listener, extended include_router by @Lancetnik in #1374
• Fix/1375 by @Lancetnik in #1377

Full Changelog: 0.5.0...0.5.1