Kafka example 
Functionalities to be added
- MongoDB integration
- Unit tests
- Integration Tests
- CI/CD with Git actions
- Postman Documentation
To run this project you will need:
Project structure
Project
├── kafka-producer-example
| ├── Dockerfile
| ├── src
| ├── main
| ├── java/com/project/kafkaexample
| ├── service: contains all of service implementation and business rules
| ├── dto: contains data transfer objects used in the integrations
| ├── api: contains controller and apis interfaces
| ├── config: contains all spring bean configuration
| ├── domain: contains all domain entity objects/classes
├── exception: contains all exception handlers
| ├── resource: contains property files and static content
├── kafka-consumer-example
| ├── Dockerfile
| ├── src
| ├── main
| ├── java/com/project/kafkaexample
| ├── service: contains all of service implementation and business rules
| ├── dto: contains data transfer objects used in the integrations
| ├── api: contains controller and apis interfaces
| ├── respository: contains all interfaces with data-bases
| ├── config: contains all spring bean configuration
| ├── domain: contains all domain entity objects/classes
| ├── exception: contains all exception handlers
| ├── resource: contains property files and static content
├── docker-compose.yml
How to build and run:
After downloading the repository, to run from scratch you must following the steps bellow:
If you want to run it from scratch:
-
▶️ go to ./kafka-consumer-example and runmvn clean package -DskipTests; - Come back to root dir;
-
▶️ go to ./kafka-producer-example and runmvn clean package -DskipTests; - Come back to root dir (again);
-
▶️ rundocker-compose up build -dor simplydocker-compose up -d - wait until all containers are up and runing
Testing:
Now it's time to use these examples by calling an api using curl or any other tools you prefer:
curl -X POST 'http://localhost:8080/api/send' -d '{"name":"Full Name", "email": "[email protected]"}' -H 'content-type: application/json'
Validating:
To check if everything was ok, go to terminal and type following commands:
docker logs kafka-producerto show kafka producer logs (here you should see a log saying you've sent a message)🟢 docker logs kafka-consumerto show kafka consumer logs (here you should see a log saying you've receved a new message)🟢 - Now it's possible to query through API the sample message sent from producer to customer:
- query all people in data-base:
curl 'http://localhost:8081/api/people?number=0&size=10'- query specific person using id: (remember replacing {id} for a valid id returned in the first query)
curl 'http://localhost:8081/api/people/{id}'
Contact
2 Jan 10, 2022
1 Feb 1, 2022
2 Mar 2, 2022
279 Dec 22, 2022
198 Dec 7, 2022
3 Nov 3, 2022
742 Jan 3, 2023
12 Jun 1, 2021
4 Oct 10, 2022
866 Dec 21, 2022