Kafka listener error handler

Author: javaHelper

13-kafka-listener-error-handler/kl-error-handler-consumer/pom.xml

@@ -5,7 +5,7 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>2.7.5</version>
+		<version>3.3.1</version>
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
 	<groupId>com.course.kafka</groupId>
@@ -60,4 +60,4 @@
 		</plugins>
 	</build>
 
-</project>
+</project>

13-kafka-listener-error-handler/kl-error-handler-consumer/src/main/java/com/course/kafka/consumer/FoodOrderConsumer.java

@@ -22,13 +22,11 @@ public class FoodOrderConsumer {
 	private ObjectMapper objectMapper;
 
 	@KafkaListener(topics = "t-food-order", errorHandler = "myFoodOrderErrorHandler")
-	public void consume(String message) throws JsonMappingException, JsonProcessingException {
+	public void consume(String message) throws JsonProcessingException {
 		var foodOrder = objectMapper.readValue(message, FoodOrder.class);
 		if (foodOrder.getAmount() > MAX_ORDER_AMOUNT) {
 			throw new IllegalArgumentException("Order amount is too many : " + foodOrder.getAmount());
 		}
-
 		LOG.info("Processing food order : {}", foodOrder);
 	}
-
-}
+}

13-kafka-listener-error-handler/kl-error-handler-consumer/src/main/java/com/course/kafka/error/handler/FoodOrderErrorHandler.java

@@ -20,5 +20,4 @@ public Object handleError(Message<?> message, ListenerExecutionFailedException e
 
 		return null;
 	}
-
-}
+}

13-kafka-listener-error-handler/kl-error-handler-producer/pom.xml

@@ -5,7 +5,7 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>2.7.5</version>
+		<version>3.3.1</version>
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
 	<groupId>com.course.kafka</groupId>
@@ -60,4 +60,4 @@
 		</plugins>
 	</build>
 
-</project>
+</project>

13-kafka-listener-error-handler/kl-error-handler-producer/src/main/java/com/course/kafka/producer/FoodOrderProducer.java

@@ -22,5 +22,4 @@ public void send(FoodOrder foodOrder) throws JsonProcessingException {
 
 		kafkaTemplate.send("t-food-order", json);
 	}
-	
-}
+}

13-kafka-listener-error-handler/kl-error-handler-producer/src/main/resources/application.yml

@@ -6,4 +6,8 @@ spring:
   main:
     banner-mode: OFF
   jackson:
-    date-format: yyyy-MMM-dd
+    date-format: yyyy-MMM-dd
+
+
+server:
+  port: 8085