This project aims to provide an event driven architecture communication system using Kafka.
This project is a simple event driven architecture communication system using Kafka.
It is mainly used for testing purposes.
Services:
- Producer: Publishes analytics events to Kafka.
- Consumer: Consumes analytics events from Kafka.
A task is executed periodically to publish events to Kafka.
The consumer application provides logs to Elasticsearch from Kafka messages.
- Java
- Spring
- Kafka
- Swagger
- Apache Maven
- Apache Kafka
- Java 17
- Maven
- Docker
To get a local copy up and running (inside docker folder):
docker-compose up -d
Run Producer and Consumer.