Using Spring Kafka for communication

Apache Kafka is a production grade, high performing, scalable, fault-tolerant messaging platform. In the application, however, we will be using the Apache Kafka topic as a message queue. Also, the Spring Kafka library will be used to enable easy communication with Apache Kafka. Spring Kafka provides the ability for templates and listeners to both produce to and consumes from Apache Kafka topics easily.

 

 

Setting up dependencies and the configuration class

Initially, before using Apache Kafka for message queue dependency and configuration, the class needs to be specified. The following Maven starter dependency needs to be included:

<dependencies>
   <dependency>
      <groupId>org.springframework.kafka</groupId>
      <artifactId>spring-kafka</artifactId>
      <version>2.1.7.RELEASE</version>
   </dependency>
</dependencies>

The preceding entries will import all the dependencies of Spring Kafka,...