kafka-poc

Spring Boot application providing Kafka producer and consumer, validating messages through Schema Registry.

How to start?

Start the Kafka, Zookeeper and Schema Registry services:

docker-compose up -d

Create the Schema Registry:

curl --location --request POST 'localhost:8081/subjects/my-topic-value/versions' \
--header 'Content-Type: application/json' \
--data-raw '{
    "references": [],
    "schemaType": "JSON",
    "schema": "{\"type\":\"object\",\"name\":\"MessageDto\",\"namespace\":\"com.co.kafkapoc.model\",\"additionalProperties\":false,\"properties\":{\"message\":{\"type\":\"string\"}},\"required\":[\"message\"]}"
}'

Compile the project:

mvn clean package

Start the application:

mvn spring-boot:run -DskipTests=true

Produce a message:

curl --location --request POST 'http://localhost:8080/kafka/produce' \
--header 'Content-Type: application/json' \
--data-raw '{
    "message": "Hello World!"
}'

Start a dynamic consumer:

curl --location --request POST 'http://localhost:8080/kafka/consumer/topic-name' \
--header 'Content-Type: application/json' \
--data-raw '{
    "message": "Hello World!"
}'

Produce a message to a dynamic consumer:

curl --location --request POST 'http://localhost:8080/kafka/produce/topic-name' \
--header 'Content-Type: application/json' \
--data-raw '{
    "message": "Hello World!"
}'

Resources

To convert JSON to String online: https://tools.knowledgewalls.com/jsontostring