v0.5.23

What's Changed

We made last release just a few days ago, but there are some big changes here already!

1. First of all - you can't use faststream run ... command without pip install faststream[cli] distribution anymore. It was made to minify default (and production) distribution by removing typer (rich and click) dependencies. CLI is a development-time feature, so if you don't need - just don't install! Special thanks to @RubenRibGarcia for this change

2. The next big change - Kafka publish confirmations by default! Previous FastStream version was working in publish & forgot style, but the new one blocks your broker.publish(...) call until Kafka confirmation frame recieved. To fallback to previous logic just use a new flag broker.publish(..., no_confirm=True)

3. Also, we made one more step forward to our 1.0.0 features plan! @KrySeyt implements get_one feature. Now you can use any broker subscriber to get messages in imperative style:

subscriber = broker.subscriber("in")
...
msg = await subscriber.get_one(timeout=5.0)

4. And the last one: @draincoder continues to develop OTEL support! Now he provides us with an ability to use OTEL spans and baggage in a comfortable FastStream-style. Just take a look at the new documentation section

Big thanks to all new and old contributors who makes such a great release!

• feat: AsgiFastStream hooks init options by @Lancetnik in #1768
• fix (#1748): add Kafka publish no_confirm option by @Lancetnik in #1749
• Fix GeneralExceptionHandler typehint by @sheldygg in #1773
• Add broker.subscriber().get_one() by @KrySeyt in #1726
• Add OTel baggage support by @draincoder in #1692
• build(#1430): separate cli faststream to its own distribution by @RubenRibGarcia in #1769

New Contributors

• @RubenRibGarcia made their first contribution in #1769

Full Changelog: 0.5.22...0.5.23