This is a clickstream app based on Nodejs, Sqlite & Apache Kafka. The app records events like add to cart, delete item from cart etc. We have docker-compose to run the application locally.
- Click streaming for multiple apis
- Co-partitioned topics for Kafka Streaming (
Work in progress) - Sqlite to persist DB with mount volumes
- JWT authentication
- Docker-compose to run the application
- E-commerce APIs like Login, Add To cart / delete, Checkout, Order Placed, Shipping
- Nodejs
- Sqlite3
- Docker & docker-compose
- Kafka cli
- Sqlite cli
https://www.postman.com/galactic-eclipse-361945/workspace/raptor9372/collection/1877749-0652fb9c-cd1d-4f1b-a822-8928d3f62119?action=share&creator=1877749
The base URL for the application that runs with docker is localhost:5001. The port 5000 is sometimes occupied in macos.
| API | Endpoint |
|---|---|
| Login | POST localhost:5001/public/authenticate |
| Add Product | POST {{base-url}}/cart/add |
| Get Cart Items | GET {{base-url}}/cart |
| Checkout | POST {{base-url}}/cart/checkout/:cartId |
| Create Order | POST {{base-url}}/orders/create |
| Get Order | GET {{base-url}}/orders/:orderId |
| Delete Cart Item | DELETE {{base-url}}/cart/delete/:cartItemId |
- Clone repository
git clone git@github.com:amol9372/click-stream-app.git-
Install Sqlite client or cli in your local machine
-
In the
docker-compose.yamlfile, change the path for mount volumes for nodejsappservice. Add the path to db folder which contains reference data & db file.
volumes:
- <path>/db:/usr/src/app/db - Run the docker-compose commands
> docker-compose build
> docker-compose upImport above postman collection to hit the apis.
The postman collection has variables for token & base-url to facilitate api testing. Once a login is successful, a token is generated & saved in postman collection variables to be used in all other APIs.
In order to place an order hit the APIs in below order:
Make sure you have installed kafka cli tools in your local system.
Once installed, we need to verify events are published to the topic or not
- List of topics
kafka-topics --bootstrap-server localhost:9092 --list- Consume data from a particular topic
kafka-console-consumer --bootstrap-server localhost:9092 --topic click_stream_auth --from-beginning --property print.key=true