1. Generate your project

First things first, we need to generate the project in Spring Initializr. Your project will have Spring MVC/web support and Apache Kafka support in the system.

As and when you unzip the project, you will get to see a very easy and sorted structure.

2. Publish messages from the Kafka topic

And then, after unzipping the project in Spring Initializr. You will be moving forward with publishing or either reading messages from the Kafka topic. Then, begin with developing a simple Java class, that you will deploy for an example package com. Demo.models;

3. Configure Kafka from application.yml configuration file

After publishing or either reading messages from Kafka topic, you have got to create the configuration file. For that matter, you have to configure your producer of Kafka and consumer in order to publish and read the messages to and from the topic. Regardless of developing or building a Java class, marking it with Configuration annotation, we can go for an application. properties file or application.yml. With the spring boot framework, we are enabled to omit all the boilerplate code that we used to write in the previous projects. And help you with quite a lot of excellent ways of configuring your application.

4. Create a producer

Developing or building a producer will write our messages on the topic.

5. Create a customer

Customer is the very service that will be taking the responsibility of reading messages and then processing them as per the requirements of your own business logic.

6. Build a rest controller

If you have successfully developed a customer, then you are already having all you require to be able to consume Kafka messages.

To have a full-fledged look that you all have built so far, you will need to make a controller with a single endpoint. The message will be then published to the endpoint, and then the producer will handle it all.

In the end, your consumer will grab and manage it the way you have set it up  by logging into the console.