ag2ai/faststream 0.3.5

v0.3.5

on GitHub

What's Changed

A large update by @Lancetnik in #1048

Provides with the ability to setup graceful_timeout to wait for consumed messages processed correctly before apllication shutdown - Broker(graceful_timeout=30.0) (waits up to 30 seconds)

• allows to get acces to context.get_local("message") from FastAPI plugin
• docs: fix Avro custom serialization example
• docs: add KafkaBroker publish_batch notice
• docs: add RabbitMQ security page
• fix: respect retry attempts with NackMessage exception
• test Kafka nack and reject behavior
• bug: fix import error with anyio version 4.x by @davorrunje in #1049

Full Changelog: 0.3.4...0.3.5