Steps to run the applications - execute via this file - run.sh
- Receive streaming bitcoin transaction data from here: https://www.blockchain.com/api/api_websocket
- Stream the transaction log to Kafka
- Analyze the transactions in realtime and count the rate of transactions on a given minute, save this in Redis
- Consume the transactions from a Kafka consumer and persist only the transactions made in the last 3 hours
- Rest API in any python framework to read from Redis to show the latest transactions