What is already done:
- Read 2 SSE streams
- Route the messages to a group of workers
- Make a sentiment analysis for each tweet
- Check for panic messages
What is already done:
- A new worker that computes the engagement ratio per tweet
- An aggregator who combine into a single object the sentiment score & the engagment ratio of the same tweet
- The backpressure mechanism - adaptive batching
- Tried to load all this data in Mongo, but it failed :| (even if locally my database works and I can manipulate with its data....)
