Implementation of CQRS with kafka and Golang
In Development…
Overview
Flow for Query (Read)
- Client (Browser) call the Api Service Facade.
- The facade calls the right service corresponding need.
- The Microservice app use Redis for respond to the query.
Flow for the Command (Create, Update, Delete)
- Client (Browser) call the Api Service Facade.
- The facade calls the right service corresponding need.
- The Microservice app will use a producer to push a new message in kafka
- Later the consumer will read the message from Kafka and execute the command related.
- The Redis data will be refresh with the current object state.
ToDo
- Interaction betwwen Microservice App
- Implement a assembler
- Etc…