kafka consumer exception handling

Author: YoonTaeMinnnn

선착순처리/consumer/src/main/java/com/example/consumer/consumer/CouponCreatedConsumer.java

@@ -2,21 +2,32 @@
 
 import com.example.consumer.domain.Coupon;
 import com.example.consumer.repository.CouponRepository;
+import com.example.consumer.repository.FailedEventRepository;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Component;
 
 @Component
 public class CouponCreatedConsumer {
 
     private final CouponRepository couponRepository;
+    private final FailedEventRepository failedEventRepository;
+    private final Logger logger = LoggerFactory.getLogger(CouponCreatedConsumer.class);
 
-    public CouponCreatedConsumer(CouponRepository couponRepository) {
+    public CouponCreatedConsumer(CouponRepository couponRepository, FailedEventRepository failedEventRepository) {
         this.couponRepository = couponRepository;
+        this.failedEventRepository = failedEventRepository;
     }
 
     @KafkaListener(topics = "coupon_create", groupId = "group_1")
     public void listener(Long userId) {
-        couponRepository.save(new Coupon(userId));
+        try {
+            couponRepository.save(new Coupon(userId));
+        } catch (Exception e) {
+            logger.error("failed to create coupon::" + userId);
+        }
+
     }
 
 

선착순처리/consumer/src/main/java/com/example/consumer/domain/FailedEvent.java

@@ -0,0 +1,25 @@
+package com.example.consumer.domain;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.Id;
+
+@Entity
+public class FailedEvent {
+
+    @Id
+    @GeneratedValue
+    @Column(name = "failed_event_id")
+    private Long id;
+
+    private Long userId;
+
+    public FailedEvent() {
+
+    }
+
+    public FailedEvent(Long userId) {
+        this.userId = userId;
+    }
+}

선착순처리/consumer/src/main/java/com/example/consumer/repository/FailedEventRepository.java

@@ -0,0 +1,8 @@
+package com.example.consumer.repository;
+
+
+import com.example.consumer.domain.FailedEvent;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface FailedEventRepository extends JpaRepository<FailedEvent, Long> {
+}