ag2ai/faststream 0.5.10

v0.5.10

on GitHub

What's Changed

Now you can return Response class to set more specific outgoing message parameters:

from faststream import Response

@broker.subscriber("in")
@broker.subscriber("out")
async def handler():
    return Response(body=b"", headers={})

• Pass logger to confluent producer and consumer by @kumaranvpl in #1464
• Fixes #1412 with TestKafkaBroker behaviour where Consumer Groups weren't being respected by @sifex in #1413
• Chore: update dependency versions by @kumaranvpl in #1478
• Remove typing-extensions version restriction by @kumaranvpl in #1477
• feat (#1431): add Response class by @Lancetnik in #1481

New Contributors

• @sifex made their first contribution in #1413

Full Changelog: 0.5.9...0.5.10