Spring Boot CQRS Example (Docker, Apache Kafka, Zookeeper, MYSQL, MongoDB)

📖 Information

CQRS (Command Query Responsibility Segregation) is an architectural pattern that separates a system into two parts: one for updating data (commands) and another for reading data (queries).
CQRS is implemented in this project with running on Docker and it provides the necessary components to build an event-driven handling with Apache Kafka

Explore Rest APIs

Method	Url	Description	Valid Request Body	Valid Request Params	Valid Request Params and Body	No Valid Request Params and Body
POST	/api/v1/openBankAccount	Open a Bank Account	Info
PUT	/api/v1/depositFunds/{id}	Deposit Fund to the Account			Info
PUT	/api/v1/withdrawFunds/{id}	Withdraw Fund from Account	Info
DELETE	/api/v1/closeBankAccount/{id}	Close Account		Info
GET	/api/v1/bankAccountLookup/	Get All Accounts				Info
GET	/api/v1/bankAccountLookup/{id}	Get Account By Id	Info
GET	/api/v1/bankAccountLookup/byHolder/{account_holder}	Get Account By Holder	Info
GET	/api/v1/bankAccountLookup/withBalance/GREATER_THAN/{value}	Get Account By Balance Greather Then Value	Info
GET	/api/v1/bankAccountLookup/withBalance/LESS_THAN/{value}	Get Account By Balance Less Then Value	Info
GET	/api/v1/restoreReadDb	Restore Database By Read				Info

Used Dependencies

Core
- Spring
  - Spring Boot
  - Spring Data
    - Spring Data JPA
Database
- Mysql
- Mongodb
Kafka
Lombok
Docker

Valid Request Body

Open a Bank Account

    http://localhost:5000/api/v1/openBankAccount
    
    {
        "accountHolder" : "Account Holder 1",
        "accountType" : "SAVINGS",
        "openingBalance" : 50.0
    }

Valid Request Params

Close Account

    http://localhost:5000/api/v1/closeBankAccount/{id}

Get Account By Id

    http://localhost:5001/api/v1/bankAccountLookup/byId/{id}

Get Account By Holder

    http://localhost:5001/api/v1/bankAccountLookup/byHolder/{account_holder}

Get Account Greather then Value

    http://localhost:5001/api/v1/bankAccountLookup/withBalance/GREATER_THAN/{value}

Get Account Less then Value

    http://localhost:5001/api/v1/bankAccountLookup/withBalance/LESS_THAN/{value}

Valid Request Params and Body

Deposit Fund to the Account

    http://localhost:5000/api/v1/depositFunds/{id}
    
    {
        "amount" : 150.0
    }

Withdraw Fund from Account

    http://localhost:5000/api/v1/withdrawFunds/{id}
    
    {
        "amount" : 50.0
    }

No Valid Request Params and Body

Get All Accounts

    http://localhost:5001/api/v1/bankAccountLookup/

Restore Database By Read

    http:localhost:5000/api/v1/restoreReadDb

🔨 Run the App

There are 2 ways to run the app.

Maven

Install mysql in your computer
Install mongodb in your computer
Run only Zookeeper and Apache Kafka from docker-compose.yml file
Download your project from this link https://github.com/Rapter1990/cqrs-example
Go to the project's home directory : cd cqrs-example
Go to the bank-account : cd bank-account
Create a jar file under bank-account directory though this command mvn clean install
Run the project though this command mvn spring-boot:run
Send any request of collection under postman collections folder through Postman
Show data from both mongodb by following all these commands shown below

    -> Open Mongodb Comprass
    -> Create a new connection (mongodb://localhost:27017)
    -> Show data from eventStore collection of bankAccount database

Show data from both mongodb by following all these commands shown below

    -> Open Mysql Workbench
    -> Use default connection
    -> Show data from bank_account table of bankAccount database

Docker Compose

Download your project from this link https://github.com/Rapter1990/cqrs-example
Go to the project's home directory : cd cqrs-example
Go to the bank-account directory : cd bank-account
Run docker-compose though this command docker-compose up --build
Send any request of collection under postman collections folder through Postman
Show data from both mongodb by following all these commands shown below

    -> docker exec -it mongo-container bash
    -> mongosh
    -> show dbs
    -> use bankAccount
    -> show collections
    -> db.eventStore.find({})

Show data from both mysql by following all these commands shown below

    -> docker exec -it mysql-database mysql -uroot -p
    -> Enter password: password defined in database
    -> USE bankAccount
    -> show tables;
    -> SELECT * FROM bank_account;