How to use Apache kafka with Spring mvc ? Is it possible?

Question

I am beginner with apache kafka and trying to learn confluent - kafka - rest - utils, however I am confusing with how can I use it.

During search I found this documentation https://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

It is very good documentation but It doesn't help me to learn rest-utils.

The git code of confluent kafka rest utils is

https://github.com/confluentinc/kafka-rest is demonstrate how to use rest kafka. But I want to know the exact procedure to be more aware about it. with some simple explanation. Can anyone suggest me some links with how I use rest client. Please guide me towards this.

It might be a silly question but I don't have other option to learn.

thanks in advance.

Answer 1

First try to create a REST service using spring MVC keeping kafka stuff aside.

Once you are able run a 'hello world' kind of REST service, then pick Kafka Docs.

Refer documents on how to create a kafka cluster, and run default console consumer and producer programs to check your cluster.

Now, write a main java program and create a kafka producer using Kafka Clients API. Refer its docs. Make sure that messages sent through main program are reaching to the consumer.

Now, inject the content of this main program in rest service, so that messages passed in request body are now passed to kafka cluster and are readable by consumer.

Hope it helps.