What's Changed
Finally, FastStream has a Kafka pattern subscription! This is another step forward in our Roadmap moving us to 0.6.0 and futher!
from faststream import Path
from faststream.kafka import KafkaBroker
broker = KafkaBroker()
@broker.subscriber(pattern="logs.{level}")
async def base_handler(
body: str,
level: str = Path(),
):
...Also, all brokers now supports a new ping method to check real broker connection
is_connected: bool = await broker.ping()This is a little, but important change for K8S probes support
More other there are a lot of bugfixes and improvements from our contributors! Thanks to all of these amazing people!
- feat(multiprocess): restart child processes if they are not alive by @gostilovichd in #1550
- fix: use typing_extensions.TypedDict import by @Lancetnik in #1575
- fix: correct single dataclass argument AsyncAPI payload generation by @Lancetnik in #1591
- fix (#1598): use config with NATS PullSub by @Lancetnik in #1599
- feat: default call_name for broker.subscriber by @KrySeyt in #1589
- Feat: init ping method by @Flosckow in #1592
- chore: bump nats-py requirement by @Lancetnik in #1600
- fix: add pattern checking by @spataphore1337 in #1590
New Contributors
- @gostilovichd made their first contribution in #1550
- @KrySeyt made their first contribution in #1589
- @Flosckow made their first contribution in #1592
Full Changelog: 0.5.14...0.5.15