Real time trading volume aggregation in Kafka
AWS MSK Serverless Live Demo
This project consist of four projects. Each project has its own documentation in README.md
Getting started AWS MSK Serverless
- Kafka Publisher and WebSocket
- Kafka Steam Aggregator
- CDK for deployment
- Create Kafka topic (demo purpose)
Getting Started (Local Development)
# init local kafka
docker-compose up -d
Then start the application in the following sequence:
Deploy
# install AWS Cloud Development Kit
nvm install 16
nvm use 16
npm install -g aws-cdk
# deploy
cd cdk
cdk deploy EcrStack
cdk deploy VpcStack
cdk deploy FargateStack
Resources for learning
Always use jib to build java/kotlin image
https://cloud.google.com/java/getting-started/jib
Kotlin Coroutine (Actor model)
- https://kt.academy/article/cc-channel
- https://kotlinlang.org/docs/shared-mutable-state-and-concurrency.html