feat: [User] delete temporary user

src/common-module/src/main/java/org/palette/dto/event/TemporaryUserDeletionEvent.java

@@ -1,9 +1,7 @@
 package org.palette.dto.event;
 
-import lombok.Getter;
 import org.palette.dto.EaselEvent;
 
-@Getter
 public record TemporaryUserDeletionEvent(String email) implements EaselEvent {
 
     @Override

src/user-service/src/main/java/org/palette/easeluserservice/EaselUserServiceApplication.java

@@ -4,6 +4,8 @@
 import org.palette.aop.LoggingAspect;
 import org.palette.aop.PassportAspect;
 import org.palette.config.CommonModuleConfig;
+import org.palette.config.KafkaConsumerConfig;
+import org.palette.config.KafkaProducerConfig;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Import;
@@ -12,7 +14,10 @@
         CommonModuleConfig.class,
         EaselAuthenticationContext.class,
         PassportAspect.class,
+        KafkaConsumerConfig.class,
+        KafkaProducerConfig.class,
         LoggingAspect.class
+
 })
 @SpringBootApplication
 public class EaselUserServiceApplication {

src/user-service/src/main/java/org/palette/easeluserservice/external/KafkaConsumer.java

@@ -0,0 +1,20 @@
+package org.palette.easeluserservice.external;
+
+import lombok.RequiredArgsConstructor;
+import org.palette.dto.event.TemporaryUserDeletionEvent;
+import org.palette.easeluserservice.usecase.UserUsecase;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class KafkaConsumer {
+
+    private final UserUsecase userUsecase;
+
+    @KafkaListener(topics = "temporary_user_deletion", groupId = "${spring.kafka.consumer.group-id}",
+            containerFactory = "kafkaListenerContainerFactory")
+    public void consumePaintCreatedEvent(TemporaryUserDeletionEvent temporaryUserDeletionEvent) {
+        userUsecase.deleteTemporaryUser(temporaryUserDeletionEvent);
+    }
+}

src/user-service/src/main/java/org/palette/easeluserservice/persistence/UserJpaRepository.java

@@ -13,4 +13,6 @@ public interface UserJpaRepository extends JpaRepository<User, Long> {
     Boolean existsByUsername(String username);
 
     Optional<User> findByEmail(String email);
+
+    void deleteByEmail(String email);
 }

src/user-service/src/main/java/org/palette/easeluserservice/service/UserService.java

@@ -111,4 +111,7 @@ public User loadById(Long id) {
         );
     }
 
+    public void deleteTemporaryUser(final String email) {
+        userJpaRepository.deleteByEmail(email);
+    }
 }

src/user-service/src/main/java/org/palette/easeluserservice/usecase/UserUsecase.java

@@ -1,6 +1,7 @@
 package org.palette.easeluserservice.usecase;
 
 import lombok.RequiredArgsConstructor;
+import org.palette.dto.event.TemporaryUserDeletionEvent;
 import org.palette.dto.event.UpdateUserEvent;
 import org.palette.easeluserservice.dto.request.EditProfileRequest;
 import org.palette.easeluserservice.dto.request.JoinRequest;
@@ -167,4 +168,8 @@ private UpdateUserEvent convertToUpdateUserEvent(User user) {
                 user.getProfile().staticContentPath().websitePath()
         );
     }
+
+    public void deleteTemporaryUser(final TemporaryUserDeletionEvent temporaryUserDeletionEvent) {
+        userService.deleteTemporaryUser(temporaryUserDeletionEvent.email());
+    }
 }

src/user-service/src/main/resources/application.yml

@@ -20,6 +20,9 @@ spring:
         use-new-id-generator-mappings: false
   kafka:
     bootstrap-servers: ${KAFKA_SERVERS}
+    consumer:
+      group-id: user-service
+      auto-offset-reset: earliest
     producer:
       key-serializer: org.apache.kafka.common.serialization.StringSerializer
       value-serializer: org.springframework.kafka.support.serializer.JsonSerializer