CQRS Debezium

A CQRS implementation using Debezium and Apache Kafka as replication method

Running the project

1. Clone the project and open it on a shell
2. Start the containers with docker compose up
3. For each microsservice, in a separate tab or shell do:
   1. cd ./microsservices/<microsservice name>
   2. make start or ./mvnw clean package && java -jar ./target/<microsservice name>.jar

Microsservices:

• command: The writer service, it uses a relational PostgreSQL database
• event-writer: The replication service, responsible from retrieving data from Apache Kafka and storing it on the OpenSearch read store
• query: The reader service, it uses a non relational OpenSearch store