🔀 :: (ENTRY-26) User 회원탈퇴 API 개발

[HyunSu1768]

close #ENTRY-26

회원탈퇴 시 Kafka delete-user 토픽에 메시지를 발행합니다.

다른 서비스에서 해당 토픽에 있는 메시지를 consume 하여 status, entryinfo를 삭제하는 로직을 수행하도록 로직을 구성해야 합니다.

그리고 Topic 에 대해서 Replica, Partition 의 개수를 실제 환경에서 Kafka 클러스터 구축을 한 뒤 더 자세히 설정할 계획입니다.

TEST

회원탈퇴 시 delete-user 토픽에 유저ID를 포함한 메시지가 발행됩니다.

[linear]

ENTRY-26 유저 회원 탈퇴 API 개발

• 유저 회원 탈퇴 API 개발
  • 회원 탈퇴시 회원 탈퇴 이벤트 발행

[lilseongwon]

안해도 되긴 하는데 interface로 추상화하거나 AOP로 적용하면 비즈니스 로직이 더러워지지 않을거 같음

[lilseongwon]

1. Service처럼 각 상황별 KafkaProducer(ex: DeleteUserProducer)클래스 안에 KafkaConfig의 kafkaTemplate.send를 사용시키면 좋을 것 같음.
2. 내가 알기론 RequestDto를 바로 전송하는게 아니라 ObjectMapper로 한번 감싸줘야 되는것으로 앎. 그래서 더더욱 Producer클래스가 묶어주면 좋을 것 같음. 아래 코드 참고하면 좋을듯

@Service
@Slf4j
@RequiredArgsConstructor
public class TestOrderProducer {
    private final KafkaTemplate<String, String> kafkaTemplate;

    public OrderDto send(String topic, OrderDto orderDto) {
        ObjectMapper mapper = new ObjectMapper();
        String jsonInString = "";

        try {
            jsonInString = mapper.writeValueAsString(orderDto);
        } catch (JsonProcessingException e) {
           e.printStackTrace();
        }

        kafkaTemplate.send(topic, jsonInString);
        log.info("Kafka Producer sent data from the Order microservice: ", orderDto);

        return orderDto;
    }
}

[HyunSu1768]

requestdto 전송하는게 저기서는 키밸류는 string,string으로 해서 직렬화 해서 주는것 같은데, 저는 밸류에 dto를 넣었기 때문에 메시지 보낼 때 KafkaConfig에서 정의해 준것 처럼 직렬화 해주는 클래스를 정의해서 직렬화 하는데 mapper가 필요할까요??

private fun producerConfig(): MutableMap<String, Any> {
        val configs: MutableMap<String, Any> = HashMap<String, Any>()
        configs[ProducerConfig.BOOTSTRAP_SERVERS_CONFIG] = kafkaProperty.serverAddress
        configs[ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG] = StringSerializer::class.java
        configs[ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG] = JsonSerializer::class.java
        return configs
    }

[lilseongwon]

내가 구현할때도 Serializer Config 설정하고 ObjectMapper사용하긴 했어
나도 정확히는 몰라서 구글링이나 Feed랑 연동해서 알아보자.
판단 될 때 merge ㄲ