chore(spring-kafka-test): aditionate producer,consumer, compose configs, global handler exception,logs and lombok in the project

Author: igorcampos-dev

spring-kafka-example/src/main/java/com/io/example/controller/ExampleController.java

@@ -0,0 +1,24 @@
+package com.io.example.controller;
+
+import com.io.example.controller.dto.request.MessageRequestDtoRequest;
+import com.io.example.controller.dto.response.GetDtoResponse;
+import com.io.example.producer.KafkaProducerService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/v1/example")
+public class ExampleController {
+
+    private final KafkaProducerService kafkaProducerService;
+
+    @PostMapping("/send")
+    public ResponseEntity<GetDtoResponse> sendMessage(@RequestBody MessageRequestDtoRequest dto){
+        this.kafkaProducerService.sendMessage(dto.message());
+        return ResponseEntity.status(HttpStatus.OK).body(new GetDtoResponse("Message sent successfully!"));
+    }
+
+}

spring-kafka-example/src/main/resources/application-dev.yml

@@ -3,7 +3,22 @@ spring:
   application:
     name: spring-kafka-example-dev
 
+  kafka:
+    topics:
+        topic-1: ${KAFKA_TOPIC_1:spring-kafka-example-topic}
+    bootstrap-servers: localhost:9092
+    consumer:
+      group-id: spring-kafka-example-group
+      auto-offset-reset: earliest
+      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+    listener:
+      missing-topics-fatal: false
+
 logging:
 
   pattern:
-    console: "%d{yyyy-MM-dd'T'HH:mm:ss} | ${spring.application.name} | %class{30} | %level | %m%n"
+    console: "%d{yyyy-MM-dd'T'HH:mm:ss} | ${spring.application.name} | %class{30} | %level | %m%n"
+
+  level:
+    org.apache.kafka.common.config: OFF

spring-kafka-example/src/main/resources/application.yml

@@ -3,7 +3,16 @@ spring:
   application:
     name: spring-kafka-example-prd
 
+  kafka:
+    bootstrap-servers: ${KAFKA_SERVER_PORT}
+    consumer:
+      group-id: myGroup
+      auto-offset-reset: earliest
+
 logging:
 
   pattern:
-    console: "%d{yyyy-MM-dd'T'HH:mm:ss} | ${spring.application.name} | %class{30} | %level | %m%n"
+    console: "%d{yyyy-MM-dd'T'HH:mm:ss} | ${spring.application.name} | %class{30} | %level | %m%n"
+
+  level:
+    org.apache.kafka.common.config: OFF

…/SpringKafkaExampleApplicationTests.java …ingKafkaExampleExampleConsumerTests.javaspring-kafka-example/src/test/java/com/io/example/SpringKafkaExampleApplicationTests.java renamed to spring-kafka-example/src/test/java/com/io/example/SpringKafkaExampleExampleConsumerTests.java spring-kafka-example/src/test/java/com/io/example/SpringKafkaExampleApplicationTests.java renamed to spring-kafka-example/src/test/java/com/io/example/SpringKafkaExampleExampleConsumerTests.java

@@ -4,7 +4,7 @@
 import org.springframework.boot.test.context.SpringBootTest;
 
 @SpringBootTest
-class SpringKafkaExampleApplicationTests {
+class SpringKafkaExampleExampleConsumerTests {
 
 	@Test
 	void contextLoads() {