chore(spring-kafka-test): geral adjustments

Author: igorcampos-dev

spring-kafka-example/pom.xml

@@ -23,6 +23,7 @@
 		<spring.boot.version>3.5.4</spring.boot.version>
 		<spring.kafka.version>3.3.8</spring.kafka.version>
 		<lombok.version>1.18.38</lombok.version>
+		<jakarta.validation.version>3.1.1</jakarta.validation.version>
 	</properties>
 
 	<dependencies>
@@ -33,6 +34,12 @@
 			<version>${spring.boot.version}</version>
 		</dependency>
 
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-validation</artifactId>
+			<version>${spring.boot.version}</version>
+		</dependency>
+
 		<dependency>
 			<groupId>org.springframework.kafka</groupId>
 			<artifactId>spring-kafka</artifactId>
@@ -46,6 +53,12 @@
 			<version>${lombok.version}</version>
 		</dependency>
 
+		<dependency>
+			<groupId>jakarta.validation</groupId>
+			<artifactId>jakarta.validation-api</artifactId>
+			<version>${jakarta.validation.version}</version>
+		</dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

spring-kafka-example/src/main/java/com/io/example/config/JacksonConfig.java

@@ -11,10 +11,9 @@ public class JacksonConfig {
 
     @Bean
     public ObjectMapper objectMapper() {
-        ObjectMapper mapper = new ObjectMapper();
-        mapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
-        mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
-        mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
-        return mapper;
+        return new ObjectMapper()
+                .configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false)
+                .disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS)
+                .setSerializationInclusion(JsonInclude.Include.NON_NULL);
     }
 }

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

@@ -3,6 +3,7 @@
 import com.io.example.controller.dto.request.MessageRequestDtoRequest;
 import com.io.example.controller.dto.response.SimpleTopicDtoResponse;
 import com.io.example.producer.KafkaProducerService;
+import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
@@ -16,7 +17,7 @@ public class ExampleController {
     private final KafkaProducerService kafkaProducerService;
 
     @PostMapping("/send/simple-topic")
-    public ResponseEntity<SimpleTopicDtoResponse> sendMessageToSimpleTopic(@RequestBody MessageRequestDtoRequest dto){
+    public ResponseEntity<SimpleTopicDtoResponse> sendMessageToSimpleTopic( @Valid @RequestBody MessageRequestDtoRequest dto){
         this.kafkaProducerService.sendMessage(dto);
         return ResponseEntity.status(HttpStatus.OK).body(new SimpleTopicDtoResponse("Message sent successfully!"));
     }

spring-kafka-example/src/main/java/com/io/example/controller/dto/request/MessageRequestDtoRequest.java

@@ -1,3 +1,10 @@
 package com.io.example.controller.dto.request;
 
-public record MessageRequestDtoRequest(String message) {}
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+
+public record MessageRequestDtoRequest(
+        @NotNull(message = "message cannot be null.")
+        @NotBlank(message = "message cannot be blank.")
+        String message
+) {}

spring-kafka-example/src/main/java/com/io/example/controller/dto/response/SimpleTopicDtoResponse.java

@@ -1,3 +1,3 @@
 package com.io.example.controller.dto.response;
 
-public record SimpleTopicDtoResponse(String message) {}
+public record SimpleTopicDtoResponse( String message) {}

spring-kafka-example/src/main/java/com/io/example/exception/handler/GlobalExceptionHandler.java

@@ -5,6 +5,8 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
+import org.springframework.validation.FieldError;
+import org.springframework.web.bind.MethodArgumentNotValidException;
 import org.springframework.web.bind.annotation.ControllerAdvice;
 import org.springframework.web.bind.annotation.ExceptionHandler;
 
@@ -14,11 +16,25 @@
 public class GlobalExceptionHandler {
 
     @ExceptionHandler(RuntimeException.class)
-    public ResponseEntity<ResponseEntity<Error>> handleRuntimeException(RuntimeException ex, HttpServletRequest s) {
+    public ResponseEntity<Error> handleRuntimeException(RuntimeException ex, HttpServletRequest s) {
         log.error("HandleRuntimeException= {}", ex.getMessage());
-        return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
-                             .body(Error.response(ex.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR, s));
+        return Error.response(ex.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR, s);
     }
 
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    public ResponseEntity<Error> handleMethodArgumentNotValidException(MethodArgumentNotValidException ex, HttpServletRequest s) {
+        log.error("HandleMethodArgumentNotValidException= {}", ex.getMessage());
+        return Error.response(this.getFirstErrorMessage(ex), HttpStatus.BAD_REQUEST, s);
+
+    }
+
+    private String getFirstErrorMessage(MethodArgumentNotValidException e) {
+        return e.getBindingResult()
+                .getFieldErrors()
+                .stream()
+                .findFirst()
+                .map(FieldError::getDefaultMessage)
+                .orElse(e.getMessage());
+    }
 
 }

spring-kafka-example/src/main/java/com/io/example/exception/responseBody/Error.java

@@ -1,15 +1,12 @@
 package com.io.example.exception.responseBody;
 
-import jakarta.servlet.ServletRequest;
 import jakarta.servlet.http.HttpServletRequest;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
-import org.springframework.web.server.ServerWebExchange;
-
 import java.time.Instant;
 import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
@@ -24,12 +21,12 @@ public class Error {
     private Integer status;
     private String error;
 
-    public static ResponseEntity<Error> response(String message, HttpStatus status, HttpServletRequest uri){
+    public static ResponseEntity<Error> response(String message, HttpStatus status, HttpServletRequest request){
         return ResponseEntity
                 .status(status)
                 .body(Error.builder()
                            .timestamp(getInstantNow())
-                           .path(uri.getRequestURI())
+                           .path(request.getRequestURI())
                            .status(status.value())
                            .error(message)
                            .build());

spring-kafka-example/src/main/java/com/io/example/mapper/JsonMapper.java

@@ -27,7 +27,7 @@ public <T> T toObject(String jsonBody, Class<T> typeClass){
             return objectMapper.readValue(jsonBody, typeClass);
         } catch (JsonProcessingException e) {
             log.error("error converting an String to object. cause of the error: {}", e.getMessage());
-            throw new RuntimeException("Object deserialization failed", e);
+            throw new IllegalArgumentException("Object deserialization failed for target type: " + typeClass.getSimpleName(), e);
         }
     }
 

spring-kafka-example/src/main/java/com/io/example/producer/KafkaProducerService.java

@@ -4,5 +4,5 @@
 
 @FunctionalInterface
 public interface KafkaProducerService {
-    void sendMessage(MessageRequestDtoRequest mensagem);
+    void sendMessage(MessageRequestDtoRequest message);
 }