The scope of this project consist of two subtasks:
- to rapidly spin-up and populate the PosgreSQL database with deleted orders streaming out of Bitstamp's API.
- to perform a SQL query to extract some insight out of the last 24 hours data.
To achieve the goal from the requirements, the project is going to spin up a cluster of 5 microservices:
- producer service: it fetches the data out of the Bitstamp's web-socket, and ingest it to a streaming queue
- streaming queue, a kafka service which collects the data and makes it available for consumers
- zookeeper needed by the kafka
- consumer service: here we read from the data stream and populate the database and aggregates the view.
- database service: where data is stored for persistance