[실습] 게시글 서비스에서 Kafka로부터 ‘회원가입 완료 이벤트’ 구독하기

JSCODE 박재성

2025-12-06

✅ 게시글 서비스에서 Kafka로부터 ‘회원가입 완료 이벤트’ 구독하기

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

1. User 엔티티 만들기
domain/User

@Entity
@Table(name = "users")
public class User {

  // Auto Increment 옵션을 사용하지 않을 거기 때문에
  // @GeneratedValue() 어노테이션 작성하지 않음
  @Id 
  private Long userId;
  
  private String name;

  public User() {
  }

  public User(Long userId, String name) {
    this.userId = userId;
    this.name = name;
  }

  public Long getUserId() {
    return userId;
  }

  public String getName() {
    return name;
  }
}

 

2. UserRepository 만들기
domain/UserRepository

public interface UserRepository extends JpaRepository<User, Long> {
}

 

3. 사용자 정보 저장 Service 로직 만들기
dto/SaveUserRequestDto

public class SaveUserRequestDto {
  private Long userId;
  private String name;

  public SaveUserRequestDto(Long userId, String name) {
    this.userId = userId;
    this.name = name;
  }

  public Long getUserId() {
    return userId;
  }

  public String getName() {
    return name;
  }
}

@Service
public class UserService {

  private final UserRepository userRepository;

  public UserService(UserRepository userRepository) {
    this.userRepository = userRepository;
  }

	@Transactional
  public void save(SaveUserRequestDto saveUserRequestDto) {
    User user = new User(
        saveUserRequestDto.getUserId(),
        saveUserRequestDto.getName()
    );

    this.userRepository.save(user);
  }
}

4. application.yml에 Kafka 연결을 위한 정보 작성하기
application.yml

server:
  port: 8081

spring:
  datasource:
    url: jdbc:mysql://localhost:3307/board-db # DB ??
    username: root # DB ??
    password: password # DB ????
    driver-class-name: com.mysql.cj.jdbc.Driver
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true
  kafka:
    # Kafka 서버 주소
    bootstrap-servers: localhost:9092
    producer:
      # 메시지의 key 직렬화 방식 : 자바 객체를 문자열(String)로 변환해서 Kafka에 전송
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      # 메시지의 value 직렬화 방식 : 자바 객체를 문자열(String)로 변환해서 Kafka에 전송
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
    consumer:
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
client:
  user-service:
    url: http://localhost:8080
  point-service:
    url: http://localhost:8082

 

2. Kafka로부터 전달받을 메시지 객체 만들기
event/UserSignedUpEvent

public class UserSignedUpEvent {
  private Long userId;
  private String name;

  // 역직렬화(String 형태의 카프카 메시지 -> Java 객체)시 빈생성자 필요함
  public UserSignedUpEvent() {
  }

  // Json 값을 UserSignedUpEvent로 역직렬화하는 메서드
  public static UserSignedUpEvent fromJson(String json) {
    try {
      ObjectMapper objectMapper = new ObjectMapper();
      return objectMapper.readValue(json, UserSignedUpEvent.class);
    } catch (JsonProcessingException e) {
      throw new RuntimeException("JSON 파싱 실패");
    }
  }

  public Long getUserId() {
    return userId;
  }

  public String getName() {
    return name;
  }
}

 

3. Kafka에 있는 메시지 Consume 하기
consumer/UserSignedUpEventConsumer

@Component
public class UserSignedUpEventConsumer {

  private final UserService userService;

  public UserSignedUpEventConsumer(UserService userService) {
    this.userService = userService;
  }

  @KafkaListener(
      topics = "user.signed-up",
      groupId = "board-service"
  )
  public void consume(String message) {
    UserSignedUpEvent userSignedUpEvent
        = UserSignedUpEvent.fromJson(message);

    // 사용자 정보 저장
    SaveUserRequestDto saveUserRequestDto
        = new SaveUserRequestDto(
            userSignedUpEvent.getUserId(),
            userSignedUpEvent.getName()
        );
    userService.save(saveUserRequestDto);
  }
}

 

7. 서버 다시 실행시키기