Handle errors better if error is thrown inside consumes function

airtai / faststream

FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.

https://faststream.airt.ai/latest/

Apache License 2.0

2.52k stars 128 forks source link

Handle errors better if error is thrown inside consumes function #111

Closed kumaranvpl closed 1 year ago

kumaranvpl commented 1 year ago

How to replicate? Follow the tutorial at https://fastkafka.airt.ai/#tutorial but don't specify the model. Run testing code

davorrunje commented 1 year ago

We'll handle this in #121