CQRS and Event Sourcing Implementation with Kafka and MySQL (JBDC)

Introduction

The aim of this small project is to illustrate the possibility of applying CQRS, Domain-Driven Design and Event Sourcing in a simple way, enabling Reactive architecture and leveraging Kafka as a distributed message broker

See: https://speakerdeck.com/vgoldin/es-and-kafka

Structure

Pre-Requisites

• JDK
• Maven
• (optional) Docker (for Kafka)

Modifying

services-inventoryitem-api and services-inventoryitem-domain modules are referencing events and commands that are defined in the services-intentoryitem-schema module as JSON.

Java source files are generated in each module that depend on these classes. This is done to avoid runtime dependency. Source files are generated as part of the mvn install cycle and are placed in the target/java-gen folder of each corresponding module.

In order to resolve all the references, this folder needs to be added as an additional java source files directory in your favorite IDE.

Building

mvn clean install

Running Services

Docker Compose

docker-compose build
docker-compose up -d

Standalone

Kafka

docker run -p 2181:2181 -p 9092:9092 --env ADVERTISED_HOST=127.0.0.1 --env ADVERTISED_PORT=9092 spotify/kafka

API Micro-Service

cd services-inventoryitem-api/target
java -jar services-inventoryitem-api-1.0-SNAPSHOT.jar server classes/application-local.yml

Domain Micro-Service

with local jdbm database

cd services-inventoryitem-domain/target
java -jar services-inventoryitem-domain-1.0-SNAPSHOT.jar server classes/application.yml

with MySQL running on 127.0.0.1:3306 (see docker-compose.yml)

cd services-inventoryitem-domain/target
java -jar services-inventoryitem-domain-1.0-SNAPSHOT.jar server classes/application-jdbc.yml

Exposed APIs

GET     /inventory-items (io.plumery.inventoryitem.api.resources.InventoryItemResource)
POST    /inventory-items (io.plumery.inventoryitem.api.resources.InventoryItemResource)
GET     /inventory-items/events.stream (io.plumery.inventoryitem.api.resources.InventoryItemResource)
PUT     /inventory-items/{id} (io.plumery.inventoryitem.api.resources.InventoryItemResource)
POST    /inventory-items/{id}/deactivate (io.plumery.inventoryitem.api.resources.InventoryItemResource)

Swagger API

• Download swagger ui from https://github.com/swagger-api/swagger-ui
• Extract the zip
• Change to dist folder
• Open index.html
• Point to:

http://localhost:9901/swagger.json

Replaying Projection

• Download and unzip Kafka
• Change to KAFKA_HOME
• Stop API Micro-Service
• Execute the following command:

./bin/kafka-streams-application-reset.sh --application-id InventoryItemsDenormalizationApplication \
                                      --input-topics InventoryItem \
                                      --bootstrap-servers localhost:9092 \
                                      --zookeeper localhost:2181

TODO

• Get rid of ID.class
• Generate all the events and commands from JSON schema
• Implement UI Micro-Service