[실습] 사용자 서비스에서 Kafka로 ‘회원가입 완료 이벤트’ 발행하기

JSCODE 박재성

2025-12-06

✅ 사용자 서비스에서 Kafka로 ‘회원가입 완료 이벤트’ 발행하기

✅ 코드 작성하기

user-service에서 아래 코드 작성하기

1. application.yml에 Kafka 설정 추가해주기

server:
  port: 8080

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/user-db 
    username: root
    password: password
    driver-class-name: com.mysql.cj.jdbc.Driver
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true
  kafka:
    # Kafka 서버 주소
    bootstrap-servers: localhost:9092
    consumer:
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

client:
  point-service:
    url: http://localhost:8082

 

2. Kafka로 전달할 메시지 객체 만들기
event/UserSignedUpEvent

public class UserSignedUpEvent {
  private Long userId;
  private String name;
  
  public UserSignedUpEvent(Long userId, String name) {
    this.userId = userId;
    this.name = name;
  }

  public Long getUserId() {
    return userId;
  }

  public String getName() {
    return name;
  }
}

 

3. 회원 가입을 완료하는 대로 Kafka 메시지 발행하도록 처리하기
service/UserService

@Service
public class UserService {
  private final UserRepository userRepository;
  private final PointClient pointClient;
  private final KafkaTemplate<String, String> kafkaTemplate;

  public UserService(UserRepository userRepository,
      PointClient pointClient,
      KafkaTemplate<String, String> kafkaTemplate) {
    this.userRepository = userRepository;
    this.pointClient = pointClient;
    this.kafkaTemplate = kafkaTemplate;
  }

  @Transactional
  public void signUp(SignUpRequestDto signUpRequestDto) {
    User user = new User(
      signUpRequestDto.getEmail(),
      signUpRequestDto.getName(),
      signUpRequestDto.getPassword()
    );

    User savedUser = this.userRepository.save(user);

    // 회원가입하면 포인트 1000점 적립
    pointClient.addPoints(savedUser.getUserId(), 1000);

    // '회원가입 완료' 이벤트 발행
    UserSignedUpEvent userSignedUpEvent = new UserSignedUpEvent(
        savedUser.getUserId(),
        savedUser.getName()
    );
    this.kafkaTemplate.send(
        "user.signed-up",
        toJsonString(userSignedUpEvent)
    );
  }

  // 객체를 Json 형태의 String으로 만들어주는 메서드
  // (클래스로 분리하면 더 좋지만 편의를 위해 메서드로만 분리)
  private String toJsonString(Object object) {
    ObjectMapper objectMapper = new ObjectMapper();
    try {
      String message = objectMapper.writeValueAsString(object);
      return message;
    } catch (JsonProcessingException e) {
      throw new RuntimeException("Json 직렬화 실패");
    }
  }
  
  ...
}

 

4. 서버 다시 실행시키기