Update pom.xml, docker-compose.yaml, src/main/java/com/example/demo/configuration/KafkaConfig.Java

docker-compose.yaml

+

pom.xml

@@ -30,6 +30,12 @@
 			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 
+		<dependency>
+            <groupId>org.springframework.kafka</groupId>
+            <artifactId>spring-kafka</artifactId>
+            <version>2.7.2</version>
+        </dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

src/main/java/com/example/demo/configuration/KafkaConfig.Java

+