It is an interesting feature request, I create an issue that you can follow the progress:

https://github.com/airtai/faststream/issues/758