Introduction

This project is an example of Kafka producing/consuming with Spring Boot and Avro format using a schema registry.

The repository contains three Spring Boot projects :

• a project to generate the required pojo from Avro
• a kafka producer fed by a controller (REST API)
• a kafka consumer that displays the received records in the logs

Run the project

POJO

First you will need to generate the POJO classes :

mvn clean install -f kafka-pojo/avro/movie/pom.xml

Kafka environment

To deploy the kafka required environment you will need docker installed and run the docker/docker-compose.yml file.

It will launch different containers:

• zookeeper
• kafka
• schema-registry
• akhq: a browser GUI to check out topics, messages and schemas
• init-kafka: init container to create the required Kafka topic and schemas

docker-compose -f docker/docker-compose.yml up -d

You will be able to access akhq on this url

Application

Once the Kafka environment started and healthy, you can start the Spring Boot projects and try them out.

Save a movie

curl --request POST \
  --url http://localhost:8090/kafka-producer/movies \
  --header 'Content-Type: application/json' \
  --data '{
	"id": 26,
	"title": "Some movie title",
	"release_date": "2022-02-26"
}'

Delete a movie

curl --request DELETE \
  --url http://localhost:8090/kafka-producer/movies/26