Quarkus Kafka Example

This is an example project that demonstrates interaction between two microservices using Apache kafka. (Producer-Consumer)

Prerequisites

1. IDE: Use an Integrated Development Environment (IDE) like IntelliJ IDEA or Eclipse.
2. Java Version: jdk 21
3. Kafka Version: Kafka 2.13-3.8.0.tgz
4. Apache Maven: apache-maven-3.9.8

Microservices

1. Microservice 1 -> code-with-micro-one
2. Microservice 2 -> code-with-micro-two

Step-by-Step Guide

1. Download apache maven from -> https://maven.apache.org/download.cgi. Set the environment variable for apache maven.

   

2. Download Kafka from -> https://kafka.apache.org/quickstart

3. Extract files in C: drive, go to project where bin and config folders are located. (C:\kafka\kafka)

4. Start Zookeeper server - Open private command prompt for the Kafka project type in the following command - bin\windows\zookeeper-server-start.bat config\zookeeper.properties and press ENTER.

5. Start Kafka server - Open another private command prompt and type in the following command - bin\windows\kafka-server-start.bat config\server.properties and press ENTER.

6. To create a Kafka topic, open another private command prompt and type in the following command - bin\windows\kafka-topics.bat --create --topic level --bootstrap-server localhost:9092 and press ENTER.

7. Run both the microservices "code-with-micro-one" and "code-with-micro-two" simultaneoulsy by typing "mvn quarkus:dev" on terminal.

Test the Application

1. Open POSTMAN and using POST method for URL -> http://localhost:8080/send and request body -> {"Hello World"} to test the Service.
2. Open "code-with-micro-two" terminal to view the received message from kafka topic "level" sent from POSTMAN to micro-service "code-with-micro-one".