Richard Hundt

I've run into the same issue, and unfortunately @florimondmanca's branch didn't work for me (all requests hang, not just SSE streams). I used that as inspiration though, and am monkey...

Something to consider: if you have a large `consumer_max_fetch_size` (default is `1024 ** 2`), have small messages, and your agent takes long to process, then you could see this issue....

Looking at the JavaScript console, it looks like it's making a call to https://serum-api.bonfida.com without enabling cross origin resource sharing (CORS). Here's the error. ``` Access to fetch at 'https://serum-api.bonfida.com/trades/address/'...

Try `stream_await_empty=False` parameter to `faust.App`. That requires idempotent message handling, and there probably is still a bug in the shutdown sequence, but if you don't mind at-least-once message delivery semantics...