This project demonstrates a simple event-driven microservices architecture where a User Service triggers events upon user registration. The events are consumed by the Email Service (via RabbitMQ) and the Analytics Service (via Kafka). The whole system is containerized using Docker and deployed with Kubernetes.

1. User Service (Spring Boot):

   • Handles user registration and stores user data in PostgreSQL.
   • Publishes events to RabbitMQ upon successful registration.

2. Email Service (Spring Boot):

   • Listens to RabbitMQ for user registration events.
   • Sends a welcome email upon receiving an event.

3. Analytics Service (Spring Boot):

   • Listens to Kafka for user registration events.
   • Logs or processes the event data for analytical purposes.

4. Infrastructure:

   • RabbitMQ: For handling messaging between User Service and Email Service.
   • Kafka: For streaming messages to the Analytics Service.
   • PostgreSQL: For persisting user data.
   • Docker & Kubernetes: For containerization and orchestration.

• Java 17
• Spring Boot (3.x)
• Spring Data JPA
• Spring AMQP (RabbitMQ)
• Spring Kafka
• PostgreSQL
• Docker
• Kubernetes (Minikube / Kind / Local Kubernetes Cluster)

├── user-service
├── email-service
├── analytics-service
├── docker-compose.yml
├── k8s
│   ├── user-service.yaml
│   ├── email-service.yaml
│   ├── analytics-service.yaml
│   ├── rabbitmq.yaml
│   ├── kafka.yaml
│   ├── zookeeper.yaml
│   └── postgresql.yaml
└── README.md

• Docker & Docker Compose
• Kubernetes (Minikube / Kind / Local Cluster)
• Java 17 & Maven

1. Build the services:

mvn clean install -DskipTests

2. Start all services:

docker-compose up --build

1. Create Kubernetes resources:

kubectl apply -f k8s/

2. Verify pods are running:

kubectl get pods

• Register a user by making a POST request to the User Service endpoint:

POST /api/v1/users/register
Content-Type: application/json
{
    "username": "johndoe",
    "email": "johndoe@example.com",
    "password": "password123"
}

• Check the logs of the Email Service and Analytics Service to confirm they received and processed the event.

• Implement User Service (Spring Boot, PostgreSQL, RabbitMQ).
• Implement Email Service (Spring Boot, RabbitMQ).
• Implement Analytics Service (Spring Boot, Kafka).
• Set up Docker Compose and Kubernetes configuration.
• Test the complete workflow.