Skip to content

Commit 5515b9b

Browse files
committed
feat: 개선된 오류 처리 로직 추가 및 Kafka 이벤트 발행 실패 로그 수정
1 parent 110c9db commit 5515b9b

1 file changed

Lines changed: 8 additions & 8 deletions

File tree

apps/commerce-api/src/main/java/com/loopers/interfaces/api/listener/UserActionEventListener.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -34,21 +34,21 @@ public void handleUserAction(UserActionEvent event) {
3434
event.metadata());
3535

3636
try {
37-
// 1. 데이터 플랫폼 전송
3837
if (isLikeOrViewAction(event)) {
3938
UserActionMessage message = convertToUserActionMessage(event);
4039
dataPlatformSender.sendUserAction(message);
41-
} else {
42-
log.info("[DataPlatform] UserAction logged: type={}, userId={}, targetId={}",
43-
event.actionType(), event.userId(), event.targetId());
4440
}
41+
} catch (Exception e) {
42+
log.error("DataPlatform 전송 실패: userId={}, actionType={}",
43+
event.userId(), event.actionType(), e);
44+
// DataPlatform 실패는 무시하고 계속 진행
45+
}
4546

46-
// 2. Kafka 이벤트 발행
47+
try {
4748
publishKafkaEvent(event);
48-
4949
} catch (Exception e) {
50-
log.error("유저 행동 처리 실패: userId={}, action={}, reason={}",
51-
event.userId(), event.actionType(), e.getMessage());
50+
log.error("Kafka 이벤트 발행 실패: userId={}, actionType={}",
51+
event.userId(), event.actionType(), e);
5252
}
5353
}
5454

0 commit comments

Comments
 (0)