[volume-9] Product Ranking with Redis #212

rkdalsdn94 · 2025-12-25T15:28:51Z

📌 Summary

Redis ZSET을 활용한 실시간 랭킹 시스템을 구현했습니다.

주요 구현 사항

Kafka 배치 리스너로 조회/좋아요/주문 이벤트를 수신하여 Redis ZSET에 실시간 점수 반영
가중치 기반 점수 계산 (조회 0.1 / 좋아요 0.2 / 주문 0.6 + 로그 정규화)
일간/실시간 이중 랭킹 시스템 (날짜별 키 분리)
콜드 스타트 문제 해결 (스케줄러를 통한 Score Carry-Over)
페이징을 포함한 랭킹 조회 API 및 상품 상세에 순위 정보 추가

💬 Review Points

콜드 스타트 관련 질문입니다.

현재 전날 점수의 10%를 다음날 키로 미리 복사하는 방식으로 선정했습니다. 선정한 이유는 다음과 같습니다. 괜찮을까요?

빈 페이지를 보여주는 문제를 해결하면서, 오늘 순위 계산에서 역전 가능하게 만들려고 했습니다. 괜찮은 방법인지 궁금하고, 어떤 부분을 더 고려하면 좋을까요?

키 설계에 관한 고민입니다.

처음에는 ranking:all로 하나의 키에 누적하고 싶었습니다.
하지만 이렇게 할 경우 멘토링 때 나왔던 오래된 인기 상품이 계속 상위 독식으로 인해 날짜별로 키를 분리했습니다.
그렇다면 날짜별로 키를 만들고 랭킹을 정렬할 때에도 걱정해야 될 부분이 있을 것 같은데.. 어떤 부분을 고려해야 할까요?
즉, ranking:all 과 ranking:time:{yyyyMMdd} 이렇게 할 때 어떤 트레이드오프를 고려하면 좋을까요?

배치 처리 크기를 어떻게 하면 좋을까요?

현재 Kafka 배치 리스너의 크기를 3000건으로 설정했습니다. 이걸 실무에서 정하는 방법? 기준? 같은 팁이 있을까요?

✅ Checklist

📈 Ranking Consumer

랭킹 ZSET 의 TTL, 키 전략을 적절하게 구성하였다
날짜별로 적재할 키를 계산하는 기능을 만들었다
이벤트가 발생한 후, ZSET 에 점수가 적절하게 반영된다

⚾ Ranking API

랭킹 Page 조회 시 정상적으로 랭킹 정보가 반환된다
랭킹 Page 조회 시 단순히 상품 ID 가 아닌 상품정보가 Aggregation 되어 제공된다
상품 상세 조회 시 해당 상품의 순위가 함께 반환된다 (순위에 없다면 null)

Summary by CodeRabbit

릴리스 노트

새로운 기능
- Kafka 기반 이벤트 발행 및 처리 시스템 구축
- 제품 순위 조회 API 추가 (일일/시간별 순위)
- 제품 조회수, 좋아요, 주문 메트릭 추적
- 이벤트 중복 처리 및 실패 관리 기능
개선 사항
- 상품 순위 정보가 포함된 제품 상세 조회
- 재고 소진 시 제품 캐시 자동 갱신

_{✏️ Tip: You can customize this high-level summary in your review settings.}

coderabbitai · 2025-12-25T15:29:02Z

Walkthrough

Kafka를 기반으로 한 이벤트 기반 아키텍처를 구현하고, 상품 순위 및 메트릭 추적 시스템을 추가했습니다. OutboxEventService가 Kafka로 이벤트를 발행하고, 새로운 commerce-streamer 서비스가 이벤트를 소비하여 메트릭과 순위를 업데이트합니다. 중복 제거(Inbox) 및 실패 처리(DLQ) 패턴을 구현했습니다.

Changes

코호트 / 파일	요약
Kafka 모듈 및 빌드 구성 `apps/commerce-api/build.gradle.kts`, `modules/kafka/src/main/java/com/loopers/confg/kafka/KafkaConfig.java`, `modules/kafka/src/main/resources/kafka.yml`	Kafka 모듈 의존성 추가, 명시적 Spring Kafka 임포트로 변경, 프로듀서 설정(idempotence, snappy compression, acks=all) 추가, 테스트 환경 offset reset 구성
Outbox 이벤트 발행자 `apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventPublisher.java`, `apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java`, `apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java`	OutboxEventPublisher에 `@ConditionalOnProperty` 추가, OutboxEventService가 EventKafkaProducer 사용하도록 변경, EventKafkaProducer 신규 생성(Kafka 토픽 발행, 비동기 처리)
상품 캐시 및 주문 통합 `apps/commerce-api/src/main/java/com/loopers/application/product/ProductCacheService.java`, `apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java`	ProductCacheService에 evictCache(Long), evictAllCache() 메서드 추가, OrderFacade에서 재고 소진 시 캐시 제거 호출
상품 순위 조회 API `apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java`, `apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingFacade.java`, `apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingApi.java`, `apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingResponse.java`	Redis ZSET 기반 RankingService(일간/실시간 순위 조회), RankingFacade(상품 정보와 병합), RankingApi(REST 엔드포인트) 신규 생성
상품 응답 DTO 확장 `apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1Controller.java`, `apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1Dto.java`, `apps/commerce-api/src/main/java/com/loopers/application/product/ProductService.java`	ProductV1Dto.ProductResponse에 rank 필드 추가, ProductV1Controller에서 RankingService 통합, ProductService.findByIds() 메서드 추가
Streamer 애플리케이션 구성 `apps/commerce-streamer/build.gradle.kts`, `apps/commerce-streamer/src/main/java/com/loopers/CommerceStreamerApplication.java`, `apps/commerce-streamer/src/main/resources/application.yml`	awaitility, testcontainers-kafka 의존성 추가, `@EnableScheduling` 추가, Kafka 토픽 설정
Streamer 이벤트 소비자 `apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java`, `apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java`	카탈로그/주문 이벤트 소비, 중복 확인(Inbox), 메트릭/순위 업데이트, DLQ로 실패 처리
메트릭 추적 도메인 `apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java`, `apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetricsRepository.java`, `apps/commerce-streamer/src/main/java/com/loopers/application/metrics/ProductMetricsService.java`, `apps/commerce-streamer/src/main/java/com/loopers/infrastructure/metrics/ProductMetrics*.java`	ProductMetrics 엔티티(좋아요, 조회, 주문 수), 메트릭 업데이트 서비스, JPA/구현 리포지토리
순위 계산 도메인 `apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingKey.java`, `apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingScore.java`, `apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingAggregator.java`, `apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingScheduler.java`	Redis ZSET 순위 키 생성, 가중치 기반 점수 계산(조회 0.1, 좋아요 0.2, 주문 0.6), 일일 순위 업데이트, 일일 이월 스케줄
Inbox/DLQ 중복 제거 및 실패 처리 `apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInbox.java`, `apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInboxRepository.java`, `apps/commerce-streamer/src/main/java/com/loopers/application/inbox/EventInboxService.java`, `apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueue.java`, `apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueueRepository.java`, `apps/commerce-streamer/src/main/java/com/loopers/application/dlq/DeadLetterQueueService.java`	EventInbox 엔티티(중복 확인), DeadLetterQueue 엔티티(실패 메시지), 각각의 서비스 및 JPA/구현 리포지토리
데이터베이스 스키마 `docker/init-db.sql`	event_inbox, product_metrics, dead_letter_queue 테이블 추가
통합 테스트 `apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceCircuitBreakerTest.java`, `apps/commerce-streamer/src/test/java/com/loopers/application/inbox/EventInboxServiceTest.java`, `apps/commerce-streamer/src/test/java/com/loopers/application/metrics/ProductMetricsServiceTest.java`, `apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/*Test.java`	회로 차단기 테스트 업데이트(atLeast 검증), Inbox/메트릭 서비스 통합 테스트, 소비자 단위/통합 테스트 추가
Kafka 학습 테스트 `modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment*.java`, `modules/kafka/src/test/java/com/loopers/kafka/learning/README.md`	자동 커밋, offset reset, poll interval, 배치 크기 동작 학습 테스트 및 문서
임포트 정리 및 기타 `apps/commerce-api/src/main/java/com/loopers/.../`, `modules/jpa/src/main/java/com/loopers/domain/BaseEntity.java`, `modules/redis/src/main/java/com/loopers/config/redis/Redis*.java`, `modules/pg-simulator/src/main/kotlin/com/loopers/`, `performance-test/`	중복 임포트 제거, 임포트 순서 정렬, 와일드카드 임포트 통합, 문서 업데이트

Sequence Diagram(s)

sequenceDiagram
    participant Client as Client
    participant OrderFacade as OrderFacade
    participant OutboxService as OutboxEventService
    participant KafkaProducer as EventKafkaProducer
    participant Kafka as Kafka Broker
    
    Client->>OrderFacade: createOrder()
    activate OrderFacade
    OrderFacade->>OrderFacade: 주문 생성, 재고 감소
    Note over OrderFacade: 재고 소진 시 캐시 제거
    OrderFacade->>OutboxService: publishEvent(outbox)
    deactivate OrderFacade
    
    activate OutboxService
    OutboxService->>KafkaProducer: publish(outbox)
    deactivate OutboxService
    
    activate KafkaProducer
    rect rgb(200, 220, 240)
        Note over KafkaProducer: 비동기 발행
        KafkaProducer->>Kafka: 메시지 발행<br/>(aggregateId 파티션 키)
    end
    Kafka-->>KafkaProducer: CompletableFuture
    KafkaProducer->>OutboxService: 성공/실패 콜백
    deactivate KafkaProducer
    
    activate OutboxService
    OutboxService->>OutboxService: 상태 업데이트(Published/Failed)
    deactivate OutboxService

sequenceDiagram
    participant Kafka as Kafka Broker
    participant CatalogConsumer as CatalogEventConsumer
    participant InboxService as EventInboxService
    participant MetricsService as ProductMetricsService
    participant RankingAgg as RankingAggregator
    participant DLQService as DeadLetterQueueService
    
    Kafka->>CatalogConsumer: 이벤트 배치 수신
    activate CatalogConsumer
    
    loop 각 이벤트
        CatalogConsumer->>InboxService: isDuplicate(eventId)
        activate InboxService
        InboxService-->>CatalogConsumer: boolean
        deactivate InboxService
        
        alt 중복 아님
            CatalogConsumer->>InboxService: save(eventId, ...)
            activate InboxService
            InboxService-->>CatalogConsumer: 저장 완료
            deactivate InboxService
            
            alt LikeCreatedEvent
                CatalogConsumer->>MetricsService: incrementLikeCount(productId)
                activate MetricsService
                MetricsService-->>CatalogConsumer: 업데이트 완료
                deactivate MetricsService
                
                CatalogConsumer->>RankingAgg: incrementLikeScore(productId)
                activate RankingAgg
                RankingAgg-->>CatalogConsumer: Redis 업데이트
                deactivate RankingAgg
            else ProductViewedEvent
                CatalogConsumer->>MetricsService: incrementViewCount(productId)
                CatalogConsumer->>RankingAgg: incrementViewScore(productId)
            end
        else 중복 감지
            Note over CatalogConsumer: 처리 스킵
        end
    end
    
    rect rgb(240, 200, 200)
        Note over CatalogConsumer: 처리 실패 시
        CatalogConsumer->>DLQService: save(topic, eventId, error)
        activate DLQService
        DLQService-->>CatalogConsumer: DLQ 저장 완료
        deactivate DLQService
    end
    
    CatalogConsumer->>Kafka: 배치 확인
    deactivate CatalogConsumer

sequenceDiagram
    participant RankingScheduler as RankingScheduler<br/>(매일 23:50)
    participant Redis as Redis
    
    activate RankingScheduler
    Note over RankingScheduler: prepareNextDayRanking() 실행
    
    RankingScheduler->>Redis: 오늘 데이터 조회<br/>(ranking:all:yyyyMMdd)
    activate Redis
    Redis-->>RankingScheduler: 순위 데이터
    deactivate Redis
    
    alt 데이터 존재
        RankingScheduler->>Redis: ZINTERSTORE로 합병<br/>(weight: 10% 적용)
        activate Redis
        Redis->>Redis: 내일 키에<br/>가중치 적용 점수 저장
        deactivate Redis
        
        RankingScheduler->>Redis: 내일 키에 TTL 설정<br/>(2일)
        activate Redis
        Redis-->>RankingScheduler: TTL 설정 완료
        deactivate Redis
    end
    
    deactivate RankingScheduler

Estimated code review effort

🎯 4 (Complex) | ⏱️ ~60 minutes

Possibly related PRs

[volume - 8] Decoupling with Kafka #209: OrderFacade 및 이벤트 발행 통합—동일한 Kafka 모듈 의존성과 OutboxEventService 변경 적용
[volume-5] Redis 캐시 및 인덱스 적용 #126: ProductCacheService 캐시 제거 메서드 및 상품 메타데이터 조회 기능 구현
[volume-5] 인덱스 및 Redis 캐시 적용 #133: ProductV1Controller 및 ProductV1Dto 확장—상품 응답에 순위 정보 추가

Poem

🐰 Kafka의 강물 따라

데이터는 흘러 Kafka 강을 건너고,
순위는 Redis에 금빛으로 빛나며,
Inbox와 DLQ로 중복 없이 정렬되고,
메트릭은 세심하게 추적되리.
🌟 이벤트 기반의 우아한 여정이여!

Pre-merge checks and finishing touches

❌ Failed checks (1 warning)

Check name	Status	Explanation	Resolution
Docstring Coverage	⚠️ Warning	Docstring coverage is 68.82% which is insufficient. The required threshold is 80.00%.	You can run `@coderabbitai generate docstrings` to improve docstring coverage.

✅ Passed checks (2 passed)

Check name	Status	Explanation
Title check	✅ Passed	PR 제목이 Redis를 활용한 상품 랭킹 시스템 구현이라는 주요 변경 사항을 명확하고 간결하게 요약하고 있습니다.
Description check	✅ Passed	PR 설명이 템플릿의 주요 섹션을 포함하고 있으며, 구현 내용과 리뷰 포인트를 상세히 설명하고 있습니다.

✨ Finishing touches

📝 Generate docstrings

🧪 Generate unit tests (beta)

Create PR with unit tests
Post copyable unit tests in a comment

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

_{Comment @coderabbitai help to get the list of available commands and usage tips.}

- RankingKey: 일간/시간별 랭킹 키 생성 전략 - RankingScore: 가중치 기반 점수 계산 (조회 0.1, 좋아요 0.2, 주문 0.6) - RankingAggregator: Redis ZSET 기반 랭킹 점수 실시간 집계 - CatalogEventConsumer: 좋아요/조회 이벤트 → 랭킹 점수 반영 - OrderEventConsumer: 주문 이벤트 → 랭킹 점수 반영 (로그 정규화 적용) - 일간 랭킹 (ranking:all:yyyyMMdd) 및 시간별 랭킹 (ranking:realtime:yyyyMMddHH) 동시 집계 - TTL: 일간 2일, 시간별 48시간 - GET /api/v1/rankings: 일간 랭킹 페이지 조회 (상품 정보 포함) - 상품 상세 조회 시 현재 랭킹 순위 정보 추가 - RankingScheduler: 매일 23:50에 내일 랭킹 키 미리 생성 - Score Carry-Over: 전날 점수의 10%를 다음 날로 복사 - Redis ZSET (Sorted Set) - Spring Data Redis - Kafka Consumer 연동 - Spring Scheduler

Consumer에 RankingAggregator 의존성이 추가되면서 테스트 코드도 함께 수정 필요 - CatalogEventConsumerTest: RankingAggregator Mock 추가 - OrderEventConsumerTest: RankingAggregator Mock 추가

- 프로덕션 환경에서의 로그 안정성 개선 - 로그 분석 도구 호환성 향상 - 인코딩 이슈 방지 변경된 파일: - RankingAggregator: 배치 점수 반영, 점수 증가 로그 - RankingScheduler: 콜드 스타트 스케줄러 로그 - CatalogEventConsumer: Catalog 이벤트 처리 로그 - OrderEventConsumer: Order 이벤트 처리 로그 - RankingService: 랭킹 조회 로그 - RankingFacade: 상품 정보 조합 로그

coderabbitai

Actionable comments posted: 16

Caution

Some comments are outside the diff and can’t be posted inline due to platform limitations.

⚠️ Outside diff range comments (2)

apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java (1)
130-155: 주문 취소 시 캐시 갱신 누락

cancelOrder 메서드에서 재고를 복구할 때 (line 147) 캐시 갱신이 없습니다. 재고가 0에서 양수로 변경될 때도 캐시를 삭제해야 다음 조회 시 최신 재고 정보가 반영됩니다.

특히 다음 시나리오에서 문제가 됩니다:

재고 0으로 캐시 삭제 → DB에서 재조회 시 stock=0 캐싱

주문 취소로 재고 복구 → 캐시는 여전히 stock=0

사용자는 품절로 표시된 상품을 볼 수 없음
🔎 제안하는 수정
 // 재고 복구 (productId로 Product 조회)
 for (OrderItem orderItem : order.getOrderItems()) {
     Product product = productRepository.findById(orderItem.getProductId())
         .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "상품을 찾을 수 없습니다."));
+    
+    boolean wasOutOfStock = product.getStock() == 0;
     product.restoreStock(orderItem.getQuantity());
+    
+    // 재고 복구 시 캐시 갱신
+    if (wasOutOfStock) {
+        log.info("재고 복구 - 캐시 갱신 - productId: {}", product.getId());
+        productCacheService.evictCache(product.getId());
+    }
 }
참고: 위 수정도 트랜잭션 경계 문제가 있으므로, 앞선 리뷰 코멘트의 이벤트 기반 접근 방식을 함께 적용하는 것을 권장합니다.
modules/kafka/src/main/resources/kafka.yml (1)
23-27: Consumer 설정에서 serializer 대신 deserializer를 사용해야 합니다.

Line 26의 value-serializer는 consumer 섹션에 있으므로 value-deserializer로 수정되어야 합니다.
🔎 제안하는 수정
     consumer:
       group-id: loopers-default-consumer
       key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-      value-serializer: org.apache.kafka.common.serialization.ByteArrayDeserializer
+      value-deserializer: org.apache.kafka.common.serialization.ByteArrayDeserializer
       properties:
         enable-auto-commit: false

🧹 Nitpick comments (33)

performance-test/README.md (2)
84-84: 참고 문서 섹션이 너무 광범위하게 축약됨

이전의 구체적인 파일 참조(.claude/round-5-performance.md, docs/week5/)가 제거되고 "프로젝트 위키 참조"로 통합되었습니다. 이로 인해 개발자가 상세한 성능 개선 내역을 찾기가 어려워질 수 있습니다.

위키 페이지에 명확한 링크 또는 앵커가 있는지 확인하고, 필요시 더 구체적인 참고 정보(예: 위키 페이지 제목 또는 섹션명)를 추가하는 것을 권장합니다.

26-68: 하드코딩된 로컬 개발 경로 수정 권장

Line 30의 MySQL 명령어가 특정 개발자의 로컬 경로(/Users/minu/Documents/project/...)로 하드코딩되어 있습니다. 다른 개발자나 CI/CD 환경에서 이 가이드를 따르기 어려울 수 있습니다.

상대 경로(../ 또는 ./ 사용) 또는 환경 변수 기반 접근으로 수정하여 재사용성을 높이는 것을 권장합니다.
🔎 권장되는 수정 방안
- cd /Users/minu/Documents/project/loopers/loopers-spring-java-template
+ # 프로젝트 루트 디렉토리로 이동
+ cd $(git rev-parse --show-toplevel)
또는 상대 경로 사용:
- cd /Users/minu/Documents/project/loopers/loopers-spring-java-template
+ # 이 README.md가 있는 디렉토리의 상위 상위 디렉토리로 이동
+ cd ../../
modules/redis/src/main/java/com/loopers/config/redis/RedisConfig.java (1)
71-86: Consumer 패턴으로 깔끔한 커스터마이제이션 구조입니다.

다만 Line 78의 null 체크는 현재 모든 호출처에서 non-null Consumer를 제공하므로 생략해도 좋습니다.
🔎 제안하는 리팩토링
-        if(customizer != null) customizer.accept(builder);
+        customizer.accept(builder);
modules/pg-simulator/src/main/kotlin/com/loopers/interfaces/api/payment/PaymentApi.kt (1)
5-8: 참고: 이 파일의 변경사항은 PR 목적과 무관해 보입니다.

이 파일은 결제 API 시뮬레이터이며, PR의 주요 목표(Redis 기반 상품 랭킹 시스템)와 직접적인 연관이 없어 보입니다. import 재구성만 포함된 것으로 보이는데, 의도하지 않은 변경사항이 포함되었는지 확인해 주세요.

선택적 제안: 와일드카드 import 지양

Line 8에서 org.springframework.web.bind.annotation.* 와일드카드 import를 사용하고 있습니다. 명시적인 개별 import가 다음과 같은 이유로 권장됩니다:

어떤 클래스가 실제로 사용되는지 명확하게 파악 가능

이름 충돌 가능성 감소

의존성 추적 용이
🔎 명시적 import로 변경하는 제안
-import org.springframework.web.bind.annotation.*
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.PostMapping
+import org.springframework.web.bind.annotation.RequestBody
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RequestParam
+import org.springframework.web.bind.annotation.RestController
modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/TransactionKeyGenerator.kt (1)
6-6: 명시적 import 사용을 고려해보세요.

현재 java.util.* 와일드카드 import를 사용하고 있지만, 이 파일에서는 UUID만 사용됩니다. 명시적 import (import java.util.UUID)를 사용하면 코드의 의존성을 더 명확하게 표현할 수 있습니다.

다만, AI 요약에 따르면 이는 관련 영역의 broader wildcard-import pattern의 일부이므로, 팀의 일관된 코드 스타일을 따르는 것이라면 현재 상태를 유지해도 괜찮습니다.
🔎 명시적 import로 변경하는 제안
-import java.util.*
+import java.util.UUID
modules/pg-simulator/src/main/kotlin/com/loopers/application/payment/PaymentApplicationService.kt (1)
3-3: 와일드카드 임포트 대신 명시적 임포트 고려

6개의 클래스를 단일 와일드카드 임포트(com.loopers.domain.payment.*)로 대체했습니다. 임포트 수가 많을 때는 와일드카드가 간결하지만, 명시적 임포트가 다음과 같은 이점을 제공합니다:

사용 중인 클래스를 명확하게 확인 가능

네이밍 충돌 방지

IDE의 미사용 임포트 감지 용이

현재 코드에서는 큰 문제가 없지만, 명시적 임포트로 유지하는 것을 선택적으로 고려해보세요.
🔎 명시적 임포트로 되돌리는 제안
-import com.loopers.domain.payment.*
+import com.loopers.domain.payment.Payment
+import com.loopers.domain.payment.PaymentEvent
+import com.loopers.domain.payment.PaymentEventPublisher
+import com.loopers.domain.payment.PaymentRelay
+import com.loopers.domain.payment.PaymentRepository
+import com.loopers.domain.payment.TransactionKeyGenerator
apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceCircuitBreakerTest.java (1)
259-265: 사용되지 않는 메서드 제거 권장

createSuccessResponse() 메서드가 정의되어 있지만 테스트 클래스 내에서 사용되지 않습니다. 성공 응답은 thenAnswer에서 인라인으로 생성하고 있으므로 이 메서드는 제거해도 됩니다.
🔎 제거 제안
-    private PgPaymentResponse createSuccessResponse() {
-        return new PgPaymentResponse(
-            "TX-" + System.currentTimeMillis(),
-            "PENDING",
-            null
-        );
-    }
-
     private FeignException createFeignException() {
apps/commerce-api/src/main/java/com/loopers/application/product/ProductCacheService.java (1)
3-4: 미사용 import 제거 필요

Line 4의 Optional import가 새로 추가된 코드에서 사용되지 않습니다. 기존 코드에서도 사용되지 않는다면 제거하는 것이 좋습니다.
🔎 제안하는 수정
 import java.time.Duration;
-import java.util.Optional;
 import lombok.RequiredArgsConstructor;
apps/commerce-streamer/src/main/resources/application.yml (1)

28-32: 토픽 설정은 기능적으로 적절하나 일관된 문서화가 부족합니다.

kafka.yml에는 Spring Kafka 클라이언트 설정만 있고, 토픽별 파티션 수, retention, replication factor 같은 상세 설정이 없습니다. 또한 application.yml의 토픽 정의에는 어떤 이벤트가 어느 토픽으로 라우팅되는지 주석이 없습니다.

권장사항:

# Kafka Topics 주석 아래 각 토픽의 용도 간단히 명시 (예: # catalog-events: 좋아요, 조회수 등 카탈로그 관련 이벤트)

kafka.yml 또는 별도 파일에 토픽의 파티션, retention, replication factor 설정 문서화 (현재 auto.create.topics.enable: false이므로 토픽 생성 방식 확인)
modules/pg-simulator/src/main/kotlin/com/loopers/PaymentGatewayApplication.kt (1)
8-8: 특정 import 사용을 권장합니다.

와일드카드 import(import java.util.*) 대신 필요한 클래스만 명시적으로 import하는 것이 Kotlin 코딩 스타일 가이드라인에 부합합니다. 현재 TimeZone만 사용되므로 구체적인 import가 더 명확합니다.
🔎 제안하는 수정
-import java.util.*
+import java.util.TimeZone
modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment2_OffsetResetTest.java (1)
210-237: Helper 메서드의 중복이 여러 테스트 클래스에서 발견됩니다.

produceMessages(int) 및 createConsumerProps(String) 메서드가 Experiment1, Experiment2, Experiment3, Experiment4 테스트 클래스 모두에서 동일하게 반복되고 있습니다.

학습 테스트의 독립성을 위해 의도적으로 중복을 유지하는 것도 선택지이지만, 공통 Helper 클래스나 Base 테스트 클래스로 추출하면 유지보수성이 향상됩니다.
선택적 리팩토링: 공통 Helper 클래스 추출

modules/kafka/src/test/java/com/loopers/kafka/learning/KafkaTestHelper.java 생성:
package com.loopers.kafka.learning;

import java.util.Properties;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.serialization.StringSerializer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class KafkaTestHelper {
    private static final Logger log = LoggerFactory.getLogger(KafkaTestHelper.class);
    private static final String BOOTSTRAP_SERVERS = "localhost:9092";

    public static void produceMessages(String topic, int count) {
        Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS);
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

        try (KafkaProducer<String, String> producer = new KafkaProducer<>(props)) {
            for (int i = 0; i < count; i++) {
                ProducerRecord<String, String> record = new ProducerRecord<>(
                    topic, "key-" + i, "Message " + i
                );
                producer.send(record);
            }
            producer.flush();
            log.info("메시지 {}개 전송 완료", count);
        }
    }

    public static Properties createConsumerProps(String groupId) {
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        return props;
    }
}
그런 다음 각 테스트 클래스에서 KafkaTestHelper.produceMessages(TOPIC, count) 및 KafkaTestHelper.createConsumerProps(groupId)로 호출할 수 있습니다.
apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingScore.java (2)
20-28: 불필요한 곱셈 연산을 제거하세요.

viewScore()와 likeScore() 메서드에서 * 1 연산은 불필요합니다. 가독성을 위해 직접 상수를 반환하는 것이 더 명확합니다.
🔎 제안하는 리팩토링
 public static double viewScore() {
-    return WEIGHT_VIEW * 1;
+    return WEIGHT_VIEW;
 }

 public static double likeScore() {
-    return WEIGHT_LIKE * 1;
+    return WEIGHT_LIKE;
 }
7-7: 유틸리티 클래스를 final로 선언하고 private 생성자를 추가하세요.

모든 메서드가 static인 유틸리티 클래스는 인스턴스화를 방지하기 위해 final로 선언하고 private 생성자를 가져야 합니다.
🔎 제안하는 수정
-public class RankingScore {
+public final class RankingScore {
+
+    private RankingScore() {
+        throw new UnsupportedOperationException("Utility class");
+    }

     // 가중치 설정
     private static final double WEIGHT_VIEW = 0.1;     // 조회
apps/commerce-streamer/src/test/java/com/loopers/application/inbox/EventInboxServiceTest.java (2)

25-28: @transactional 롤백과 중복된 정리 로직

각 테스트 메서드에 @Transactional이 적용되어 자동으로 롤백되므로, deleteAll()은 불필요할 수 있습니다. 다만, 테스트 간 격리를 명시적으로 보장하려는 의도라면 유지해도 무방합니다.

30-69: 테스트 커버리지 확장 권장

현재 기본 흐름만 검증하고 있습니다. 다음 시나리오 추가를 고려해보세요:

eventId가 null이거나 빈 문자열인 경우

동시성 시나리오 (동일 eventId에 대한 동시 save 호출)

트랜잭션 실패 시나리오

docker/init-db.sql (2)

19-19: soft delete 미사용 시 deleted_at 제거 권장

deleted_at 컬럼이 선언되어 있지만, 관련 인덱스나 삭제 로직이 보이지 않습니다. Soft delete를 실제로 사용하지 않는다면 컬럼 제거를 고려하세요.

Also applies to: 55-55

32-32: 통화/단위 정보 누락

sales_amount DECIMAL(15,2)는 금액을 저장하지만 통화 단위가 명시되지 않았습니다. 다중 통화를 지원할 계획이 있다면 currency 컬럼 추가를 고려하세요.
apps/commerce-streamer/src/main/java/com/loopers/application/dlq/DeadLetterQueueService.java (2)
46-47: 로그 메시지의 이모지 제거 권장

로그 메시지에 이모지 ⚠️가 포함되어 있습니다. 일부 로그 수집 시스템이나 인코딩 환경에서 문제를 일으킬 수 있으므로, 텍스트로 대체하는 것을 권장합니다.
🔎 제안 수정
-        log.error("⚠️ DLQ에 메시지 저장 - topic: {}, eventId: {}, retryCount: {}, error: {}",
+        log.error("[DLQ] 메시지 저장 - topic: {}, eventId: {}, retryCount: {}, error: {}",
             originalTopic, eventId, retryCount, errorMessage);
32-42: payload/errorMessage 크기 제한 누락

DB 스키마에서 payload와 error_message는 TEXT 타입이지만, 매우 큰 페이로드나 에러 메시지가 전달될 경우 저장 실패 가능성이 있습니다. 크기 제한을 추가하거나 truncate 로직을 고려하세요.
apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java (1)

102-125: 사용되지 않는 코드 제거 고려

deserializeEvent, getEventClass, getPackageName 메서드가 이 클래스 내에서 호출되지 않습니다. Kafka 발행 방식으로 리팩토링되면서 더 이상 필요하지 않은 것으로 보입니다.
apps/commerce-streamer/src/test/java/com/loopers/application/metrics/ProductMetricsServiceTest.java (1)
46-60: 엣지 케이스 테스트 추가 권장

decrementLikeCount가 좋아요 수가 0일 때 호출되면 어떻게 되는지 테스트가 없습니다. 음수 방지 로직이 서비스에 있는지 확인하고, 해당 동작을 검증하는 테스트를 추가하는 것이 좋습니다.
🔎 제안: 엣지 케이스 테스트 추가
@Test
void 좋아요_수가_0일때_감소시_음수가_되지_않는다() {
    // Given
    Long productId = 5L;
    productMetricsService.incrementLikeCount(productId);

    // When
    productMetricsService.decrementLikeCount(productId);
    productMetricsService.decrementLikeCount(productId);  // 0 이하로 감소 시도

    // Then
    ProductMetrics metrics = productMetricsRepository.findByProductId(productId)
        .orElseThrow();
    assertThat(metrics.getLikeCount()).isGreaterThanOrEqualTo(0);
}
apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java (1)

18-29: @Value 필드와 @RequiredArgsConstructor 혼용 주의

@RequiredArgsConstructor는 final 필드에 대해서만 생성자를 생성하지만, @Value 어노테이션 필드(catalogEventsTopic, orderEventsTopic)는 final이 아닙니다. Spring이 빈 생성 후 @Value 필드를 주입하므로 현재 코드는 동작하지만, 명시적 생성자 주입이나 @ConfigurationProperties를 사용하는 것이 더 명확합니다.
apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingFacade.java (1)
73-76: 날짜 포맷터 중복 제거 고려

DateTimeFormatter.ofPattern("yyyyMMdd")가 RankingService에도 존재합니다. 공통 상수나 RankingKey.dailyToday() 메서드를 활용하여 중복을 줄일 수 있습니다.
🔎 제안: RankingKey 활용
 public List<RankingProductInfo> getTodayRanking(int page, int size) {
-    String today = java.time.LocalDate.now().format(java.time.format.DateTimeFormatter.ofPattern("yyyyMMdd"));
+    String today = java.time.LocalDate.now().format(java.time.format.DateTimeFormatter.ofPattern("yyyyMMdd"));
+    // 또는 RankingKey에서 날짜 문자열 추출 로직을 공유
     return getDailyRanking(today, page, size);
 }
더 나은 방법은 RankingKey 클래스에 날짜 포맷팅 유틸리티를 추가하는 것입니다.
apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingApi.java (1)
36-45: 페이지 파라미터 유효성 검증 권장

page와 size에 대한 유효성 검증이 없습니다. 음수 값이나 과도하게 큰 size가 입력될 경우 Redis에 부하가 발생하거나 예기치 않은 동작이 발생할 수 있습니다.
🔎 제안: 파라미터 검증 추가
 @GetMapping
 public ResponseEntity<RankingResponse> getRankings(
     @Parameter(description = "조회 날짜 (yyyyMMdd), 미입력 시 오늘", example = "20250123")
     @RequestParam(required = false) String date,

     @Parameter(description = "페이지 번호 (1부터 시작)", example = "1")
-    @RequestParam(defaultValue = "1") int page,
+    @RequestParam(defaultValue = "1") @Min(1) int page,

     @Parameter(description = "페이지 크기", example = "20")
-    @RequestParam(defaultValue = "20") int size
+    @RequestParam(defaultValue = "20") @Min(1) @Max(100) int size
 ) {
@Validated를 컨트롤러 클래스에 추가하고 jakarta.validation.constraints.Min, Max를 import하세요.
apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingKey.java (1)
10-16: 유틸리티 클래스 패턴 개선 권장

모든 메서드가 static이므로 인스턴스화 방지를 위해 private 생성자를 추가하는 것이 좋습니다.
🔎 제안: private 생성자 추가
 public class RankingKey {
+
+    private RankingKey() {
+        // Utility class
+    }

     private static final String DAILY_PREFIX = "ranking:all:";
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java (1)
125-126: 중복 JSON 파싱

processOrderCreated에서 payload를 다시 파싱하고 있습니다. processEvent에서 이미 파싱된 eventData를 파라미터로 전달하면 불필요한 파싱을 줄일 수 있습니다.
🔎 리팩토링 제안
-    private void processOrderCreated(String payload) throws Exception {
-        Map<String, Object> eventData = objectMapper.readValue(payload, Map.class);
+    private void processOrderCreated(Map<String, Object> eventData) throws Exception {
호출부:
         if ("OrderCreatedEvent".equals(eventType)) {
-            processOrderCreated(payload);
+            processOrderCreated(eventData);
apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java (1)

41-48: Integer 카운터 오버플로우 가능성

likeCount, viewCount, orderCount가 Integer 타입입니다. 인기 상품의 경우 조회수가 Integer.MAX_VALUE(약 21억)를 초과할 수 있습니다. 트래픽 규모에 따라 Long 타입 사용을 고려하세요.

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java (2)

35-35: 사용되지 않는 상수 MAX_RETRY

MAX_RETRY 상수가 정의되어 있지만 코드에서 사용되지 않습니다. 향후 재시도 로직을 구현할 계획이 아니라면 제거하세요.

24-172: OrderEventConsumer와 코드 중복

CatalogEventConsumer와 OrderEventConsumer가 거의 동일한 구조를 가지고 있습니다. 공통 로직(배치 처리, Inbox 체크, DLQ 전송)을 추상 베이스 클래스나 공통 유틸리티로 추출하면 유지보수성이 향상됩니다.

apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/OrderEventConsumerTest.java (1)

51-61: DeadLetterQueueService가 null로 설정됨

DeadLetterQueueService를 null로 전달하면, 예외 발생 시 sendToDLQ에서 NullPointerException이 발생할 수 있습니다. 단위 테스트에서 예외 처리 경로를 테스트하려면 mock 객체를 사용하거나, 예외 테스트 케이스를 명시적으로 분리하세요.
apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java (3)
24-26: 사용되지 않는 상수 HOURLY_PREFIX

HOURLY_PREFIX가 정의되어 있지만 코드에서 사용되지 않습니다. 향후 시간별 랭킹 조회 기능을 추가할 계획이라면 유지하고, 아니라면 제거하세요.

44-47: 시스템 기본 타임존 사용

LocalDate.now()는 시스템 기본 타임존을 사용합니다. 분산 환경이나 다른 타임존의 서버에서 일관되지 않은 결과가 발생할 수 있습니다. 명시적 타임존 지정을 고려하세요.
LocalDate.now(ZoneId.of("Asia/Seoul"))
Also applies to: 67-70

102-104: Long.parseLong 예외 처리 누락

Redis ZSET에 저장된 값이 숫자가 아닐 경우 NumberFormatException이 발생합니다. 데이터 무결성이 보장된다면 현재 구현도 괜찮지만, 방어적으로 처리하려면 try-catch를 추가하세요.

📜 Review details

Configuration used: Repository UI

Review profile: CHILL

Plan: Pro

📥 Commits

Reviewing files that changed from the base of the PR and between 9c7961e and f6c8979.

📒 Files selected for processing (81)

apps/commerce-api/build.gradle.kts
apps/commerce-api/src/main/java/com/loopers/CommerceApiApplication.java
apps/commerce-api/src/main/java/com/loopers/application/dataplatform/DataPlatformEventHandler.java
apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java
apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java
apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventPublisher.java
apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java
apps/commerce-api/src/main/java/com/loopers/application/product/ProductCacheService.java
apps/commerce-api/src/main/java/com/loopers/application/product/ProductService.java
apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingFacade.java
apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java
apps/commerce-api/src/main/java/com/loopers/application/user/UserFacade.java
apps/commerce-api/src/main/java/com/loopers/config/CacheConfig.java
apps/commerce-api/src/main/java/com/loopers/infrastructure/dataplatform/DataPlatformClientConfig.java
apps/commerce-api/src/main/java/com/loopers/infrastructure/example/ExampleRepositoryImpl.java
apps/commerce-api/src/main/java/com/loopers/infrastructure/payment/PgPaymentRequest.java
apps/commerce-api/src/main/java/com/loopers/interfaces/api/ApiControllerAdvice.java
apps/commerce-api/src/main/java/com/loopers/interfaces/api/payment/PaymentApi.java
apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1Controller.java
apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1Dto.java
apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingApi.java
apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingResponse.java
apps/commerce-api/src/main/resources/application.yml
apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceCircuitBreakerTest.java
apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceFallbackTest.java
apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceRetryTest.java
apps/commerce-api/src/test/java/com/loopers/domain/example/ExampleModelTest.java
apps/commerce-api/src/test/java/com/loopers/domain/example/ExampleServiceIntegrationTest.java
apps/commerce-api/src/test/java/com/loopers/interfaces/api/ExampleV1ApiE2ETest.java
apps/commerce-api/src/test/java/com/loopers/support/error/CoreExceptionTest.java
apps/commerce-streamer/build.gradle.kts
apps/commerce-streamer/src/main/java/com/loopers/CommerceStreamerApplication.java
apps/commerce-streamer/src/main/java/com/loopers/application/dlq/DeadLetterQueueService.java
apps/commerce-streamer/src/main/java/com/loopers/application/inbox/EventInboxService.java
apps/commerce-streamer/src/main/java/com/loopers/application/metrics/ProductMetricsService.java
apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingAggregator.java
apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingScheduler.java
apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueue.java
apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueueRepository.java
apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInbox.java
apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInboxRepository.java
apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java
apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetricsRepository.java
apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingKey.java
apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingScore.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/dlq/DeadLetterQueueJpaRepository.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/dlq/DeadLetterQueueRepositoryImpl.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/inbox/EventInboxJpaRepository.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/inbox/EventInboxRepositoryImpl.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsJpaRepository.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsRepositoryImpl.java
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/DemoKafkaConsumer.java
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java
apps/commerce-streamer/src/main/resources/application.yml
apps/commerce-streamer/src/test/java/com/loopers/application/inbox/EventInboxServiceTest.java
apps/commerce-streamer/src/test/java/com/loopers/application/metrics/ProductMetricsServiceTest.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/CatalogEventConsumerTest.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/ConsumerSmokeTest.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/OrderEventConsumerTest.java
docker/init-db.sql
modules/jpa/src/main/java/com/loopers/domain/BaseEntity.java
modules/jpa/src/testFixtures/java/com/loopers/utils/DatabaseCleanUp.java
modules/kafka/src/main/java/com/loopers/confg/kafka/KafkaConfig.java
modules/kafka/src/main/resources/kafka.yml
modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment1_AutoCommitTest.java
modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment2_OffsetResetTest.java
modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment3_PollIntervalTest.java
modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment4_BatchSizeTest.java
modules/kafka/src/test/java/com/loopers/kafka/learning/README.md
modules/pg-simulator/src/main/kotlin/com/loopers/PaymentGatewayApplication.kt
modules/pg-simulator/src/main/kotlin/com/loopers/application/payment/PaymentApplicationService.kt
modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/Payment.kt
modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/TransactionKeyGenerator.kt
modules/pg-simulator/src/main/kotlin/com/loopers/interfaces/api/ApiControllerAdvice.kt
modules/pg-simulator/src/main/kotlin/com/loopers/interfaces/api/payment/PaymentApi.kt
modules/redis/src/main/java/com/loopers/config/redis/RedisConfig.java
modules/redis/src/main/java/com/loopers/config/redis/RedisProperties.java
performance-test/README.md
performance-test/k6/product-load-test-fixed.js
performance-test/k6/product-load-test.js

💤 Files with no reviewable changes (6)

apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceFallbackTest.java
apps/commerce-api/src/main/java/com/loopers/interfaces/api/payment/PaymentApi.java
modules/pg-simulator/src/main/kotlin/com/loopers/interfaces/api/ApiControllerAdvice.kt
apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceRetryTest.java
apps/commerce-api/src/main/java/com/loopers/infrastructure/payment/PgPaymentRequest.java
apps/commerce-api/src/main/java/com/loopers/application/user/UserFacade.java

🧰 Additional context used

🧠 Learnings (17)

📓 Common learnings

Learnt from: kilian-develop
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 190
File: apps/commerce-streamer/src/main/java/com/loopers/applications/streamer/consumer/product/IncreaseProductViewKafkaConsumer.java:25-35
Timestamp: 2025-12-18T13:24:54.339Z
Learning: In this codebase, Kafka consumers delegate error handling and event tracking to the service layer via EventInboxAspect. Service methods annotated with InboxEvent are intercepted by the aspect, which handles failures by saving failed EventInbox entries and logging errors. This centralized approach avoids duplicating error handling logic across multiple consumers.

Learnt from: toongri
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 68
File: docs/week8/round8-detailed-design.md:151-178
Timestamp: 2025-12-19T20:59:50.009Z
Learning: In the Loopers-dev-lab/loopers-spring-kotlin-template repository's Kafka event pipeline, only 5 domain events are intentionally published to Kafka via CloudEventEnvelopeFactory: OrderPaidEventV1, LikeCreatedEventV1, LikeCanceledEventV1, ProductViewedEventV1, and StockDepletedEventV1. Other domain events (OrderCreatedEventV1, OrderCanceledEventV1, PaymentCreatedEventV1, PaymentPaidEventV1, PaymentFailedEventV1) are internal-only and intentionally not mapped in resolveMetadata(), which correctly returns null for them to exclude them from Outbox publication.

📚 Learning: 2025-12-19T03:23:54.756Z

Learnt from: minor7295
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 191
File: modules/kafka/src/testFixtures/java/com/loopers/testcontainers/KafkaTestContainersConfig.java:24-34
Timestamp: 2025-12-19T03:23:54.756Z
Learning: In the loopers-spring-java-template project, test container configurations (MySQL, Redis, Kafka) use static initialization blocks for consistency across the template. This pattern should be maintained for uniformity, even if alternative lifecycle management approaches exist.

Applied to files:

apps/commerce-api/src/test/java/com/loopers/interfaces/api/ExampleV1ApiE2ETest.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/ConsumerSmokeTest.java
modules/kafka/src/main/java/com/loopers/confg/kafka/KafkaConfig.java

📚 Learning: 2025-11-27T09:09:24.961Z

Learnt from: sky980221
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 121
File: apps/commerce-api/src/main/java/com/loopers/infrastructure/product/ProductJpaRepository.java:22-24
Timestamp: 2025-11-27T09:09:24.961Z
Learning: Product 엔티티 (apps/commerce-api/src/main/java/com/loopers/domain/product/Product.java)는 유즈케이스별로 의도적으로 다른 락 전략을 사용한다: 좋아요 기능에는 비관적 락(findByIdForUpdate)을, 재고 차감에는 낙관적 락(Version + 재시도)을 사용한다.

Applied to files:

apps/commerce-api/src/main/java/com/loopers/application/product/ProductService.java
apps/commerce-api/src/main/java/com/loopers/application/product/ProductCacheService.java
apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java
apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetricsRepository.java
apps/commerce-streamer/src/test/java/com/loopers/application/metrics/ProductMetricsServiceTest.java
apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java
apps/commerce-streamer/src/main/java/com/loopers/application/metrics/ProductMetricsService.java

📚 Learning: 2025-12-02T08:12:06.383Z

Learnt from: junoade
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 0
File: :0-0
Timestamp: 2025-12-02T08:12:06.383Z
Learning: ProductQueryService에서 상품 목록 조회 시 Redis 캐시를 적용했으며, 캐시 키는 brandId, sortType, pageNumber, pageSize의 조합으로 구성되고 TTL은 5분으로 설정되어 있다.

Applied to files:

apps/commerce-api/src/main/java/com/loopers/application/product/ProductService.java
apps/commerce-api/src/main/java/com/loopers/application/product/ProductCacheService.java

📚 Learning: 2025-12-19T20:59:50.009Z

Learnt from: toongri
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 68
File: docs/week8/round8-detailed-design.md:151-178
Timestamp: 2025-12-19T20:59:50.009Z
Learning: In the Loopers-dev-lab/loopers-spring-kotlin-template repository's Kafka event pipeline, only 5 domain events are intentionally published to Kafka via CloudEventEnvelopeFactory: OrderPaidEventV1, LikeCreatedEventV1, LikeCanceledEventV1, ProductViewedEventV1, and StockDepletedEventV1. Other domain events (OrderCreatedEventV1, OrderCanceledEventV1, PaymentCreatedEventV1, PaymentPaidEventV1, PaymentFailedEventV1) are internal-only and intentionally not mapped in resolveMetadata(), which correctly returns null for them to exclude them from Outbox publication.

Applied to files:

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java
docker/init-db.sql
apps/commerce-streamer/src/main/java/com/loopers/application/inbox/EventInboxService.java
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/inbox/EventInboxRepositoryImpl.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/CatalogEventConsumerTest.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/ConsumerSmokeTest.java
apps/commerce-streamer/src/test/java/com/loopers/application/inbox/EventInboxServiceTest.java
apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInboxRepository.java
apps/commerce-streamer/src/main/resources/application.yml
apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInbox.java
modules/pg-simulator/src/main/kotlin/com/loopers/application/payment/PaymentApplicationService.kt
apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java
apps/commerce-api/src/main/resources/application.yml
apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java
apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueue.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/OrderEventConsumerTest.java

📚 Learning: 2025-12-18T13:24:51.650Z

Learnt from: kilian-develop
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 190
File: apps/commerce-streamer/src/main/java/com/loopers/applications/streamer/consumer/product/IncreaseProductViewKafkaConsumer.java:25-35
Timestamp: 2025-12-18T13:24:51.650Z
Learning: Adopt centralized error handling for Kafka consumers by using the EventInboxAspect to intercept methods annotated with InboxEvent. Ensure that service methods annotated with InboxEvent save failed EventInbox entries and log errors, avoiding duplicating error handling logic in individual consumers. Apply this pattern broadly to similar consumer/service layers within the commerce-streamer module.

Applied to files:

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/DemoKafkaConsumer.java

📚 Learning: 2025-12-19T21:30:08.018Z

Learnt from: toongri
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 68
File: apps/commerce-api/src/main/kotlin/com/loopers/infrastructure/outbox/OutboxEventListener.kt:0-0
Timestamp: 2025-12-19T21:30:08.018Z
Learning: In the Loopers-dev-lab/loopers-spring-kotlin-template Kafka event pipeline, Like events (LikeCreatedEventV1, LikeCanceledEventV1) intentionally use aggregateType="Like" with aggregateId=productId. The aggregateId serves as a partitioning/grouping key (not a unique Like entity identifier), ensuring all like events for the same product go to the same partition for ordering guarantees and aligning with ProductStatisticService's product-based aggregation logic. Using individual like_id would scatter events across partitions and break the statistics aggregation pattern.

Applied to files:

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/CatalogEventConsumerTest.java
apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java
apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java

📚 Learning: 2025-12-19T23:39:16.424Z

Learnt from: toongri
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 68
File: apps/commerce-streamer/src/main/kotlin/com/loopers/interfaces/consumer/product/ProductEventConsumer.kt:0-0
Timestamp: 2025-12-19T23:39:16.424Z
Learning: In Loopers-dev-lab/loopers-spring-kotlin-template, toongri prefers pragmatic idempotency handling in Kafka consumers: when idempotency key persistence fails after successful business logic execution, log a warning and continue (accepting low risk of duplicates on retry) rather than rolling back business data. This keeps business logic decoupled from idempotency store (which might be Redis/external system, not RDB), avoids over-engineering for rare edge cases, and prioritizes core business value over auxiliary metadata. Transaction-based atomicity between business data and idempotency keys is considered excessive when duplicate event probability is very low.

Applied to files:

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java
docker/init-db.sql
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java
modules/kafka/src/main/resources/kafka.yml
apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java

📚 Learning: 2025-12-18T13:24:54.339Z

Learnt from: kilian-develop
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 190
File: apps/commerce-streamer/src/main/java/com/loopers/applications/streamer/consumer/product/IncreaseProductViewKafkaConsumer.java:25-35
Timestamp: 2025-12-18T13:24:54.339Z
Learning: In this codebase, Kafka consumers delegate error handling and event tracking to the service layer via EventInboxAspect. Service methods annotated with InboxEvent are intercepted by the aspect, which handles failures by saving failed EventInbox entries and logging errors. This centralized approach avoids duplicating error handling logic across multiple consumers.

Applied to files:

apps/commerce-streamer/src/main/java/com/loopers/application/inbox/EventInboxService.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/CatalogEventConsumerTest.java
apps/commerce-streamer/src/test/java/com/loopers/application/inbox/EventInboxServiceTest.java
apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInbox.java
apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java
apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java
apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/OrderEventConsumerTest.java

📚 Learning: 2025-12-19T09:30:12.459Z

Learnt from: HongChangMo
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 198
File: apps/commerce-api/src/main/java/com/loopers/application/payment/PaymentEventListener.java:0-0
Timestamp: 2025-12-19T09:30:12.459Z
Learning: In the loopers-spring-java-template repository's commerce-api module, when entities are managed within a transactional context (e.g., Transactional methods), prefer relying on JPA dirty checking for automatic persistence rather than explicit save() calls. Both Payment and Order entities in PaymentEventListener use this pattern, with state changes automatically flushed on transaction commit.

Applied to files:

apps/commerce-streamer/src/main/java/com/loopers/application/inbox/EventInboxService.java
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/inbox/EventInboxRepositoryImpl.java
apps/commerce-api/src/main/java/com/loopers/application/dataplatform/DataPlatformEventHandler.java
apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/dlq/DeadLetterQueueRepositoryImpl.java
modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/Payment.kt
apps/commerce-api/src/test/java/com/loopers/domain/example/ExampleServiceIntegrationTest.java
apps/commerce-streamer/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsRepositoryImpl.java
modules/pg-simulator/src/main/kotlin/com/loopers/application/payment/PaymentApplicationService.kt
apps/commerce-api/src/main/java/com/loopers/infrastructure/example/ExampleRepositoryImpl.java
apps/commerce-streamer/src/main/java/com/loopers/application/metrics/ProductMetricsService.java

📚 Learning: 2025-12-16T09:44:15.945Z

Learnt from: toongri
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 58
File: apps/commerce-api/src/main/kotlin/com/loopers/domain/payment/PaymentService.kt:157-183
Timestamp: 2025-12-16T09:44:15.945Z
Learning: In PaymentService.requestPgPayment (apps/commerce-api/src/main/kotlin/com/loopers/domain/payment/PaymentService.kt), PG payment requests are idempotent using paymentId as the idempotency key, so Retryable covering the entire method including the pgClient.requestPayment call is safe and will not cause duplicate charges even if retries occur due to ObjectOptimisticLockingFailureException.

Applied to files:

apps/commerce-api/src/test/java/com/loopers/application/payment/PaymentServiceCircuitBreakerTest.java
modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/Payment.kt
modules/pg-simulator/src/main/kotlin/com/loopers/application/payment/PaymentApplicationService.kt

📚 Learning: 2025-11-20T13:22:51.519Z

Learnt from: kilian-develop
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 98
File: core/domain/src/main/java/com/loopers/core/domain/order/DefaultCoupon.java:15-62
Timestamp: 2025-11-20T13:22:51.519Z
Learning: In the order domain coupon implementation, DefaultCoupon serves as an internal helper/DTO class to carry AbstractCoupon's base fields during database reconstruction. It is used as an intermediate object when converting CouponEntity to specific coupon types (RateDiscountCoupon or AmountDiscountCoupon). The actual discount information (rate/amount) is stored in separate tables (rate_discount_coupon and amount_discount_coupon) and fetched via RateDiscountCouponJpaRepository and AmountDiscountCouponJpaRepository. DefaultCoupon is never returned to callers directly.

Applied to files:

apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java

📚 Learning: 2025-12-19T03:23:51.674Z

Learnt from: minor7295
Repo: Loopers-dev-lab/loopers-spring-java-template PR: 191
File: modules/kafka/src/testFixtures/java/com/loopers/testcontainers/KafkaTestContainersConfig.java:24-34
Timestamp: 2025-12-19T03:23:51.674Z
Learning: Maintain the use of static initialization blocks in test fixtures for testcontainers configurations (e.g., MySQL, Redis, Kafka) to ensure consistency and predictable initialization across the loopers-spring-java-template project. Apply this pattern to all test-fixture Java files under src/testFixtures/java to preserve uniform lifecycle behavior, unless there's a compelling, well-justified reason to diverge.

Applied to files:

modules/jpa/src/testFixtures/java/com/loopers/utils/DatabaseCleanUp.java

📚 Learning: 2025-12-20T00:38:25.765Z

Learnt from: toongri
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 68
File: apps/commerce-api/src/main/kotlin/com/loopers/infrastructure/outbox/OutboxRelayService.kt:46-52
Timestamp: 2025-12-20T00:38:25.765Z
Learning: In OutboxRelayService in apps/commerce-api (Loopers-dev-lab/loopers-spring-kotlin-template), the scheduler uses fixedDelay which guarantees serial execution within a single JVM instance, so Volatile is sufficient for backoff state variables (consecutiveFailures, nextAllowedTime) and AtomicInteger/AtomicLong are not necessary for thread safety.

Applied to files:

apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventPublisher.java
apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java

📚 Learning: 2025-11-09T10:41:39.297Z

Learnt from: ghojeong
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 25
File: apps/commerce-api/src/main/kotlin/com/loopers/domain/product/ProductRepository.kt:1-12
Timestamp: 2025-11-09T10:41:39.297Z
Learning: In this codebase, domain repository interfaces are allowed to use Spring Data's org.springframework.data.domain.Page and org.springframework.data.domain.Pageable types. This is an accepted architectural decision and should not be flagged as a DIP violation.

Applied to files:

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/dlq/DeadLetterQueueJpaRepository.java

📚 Learning: 2025-12-22T16:33:42.960Z

Learnt from: jikimee64
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 71
File: apps/commerce-streamer/src/main/kotlin/com/loopers/application/ranking/RankingFacade.kt:167-173
Timestamp: 2025-12-22T16:33:42.960Z
Learning: In the Loopers-dev-lab/loopers-spring-kotlin-template repository, using system default timezone (ZonedDateTime.now() without explicit ZoneId) in date key calculations is an intentional design choice. The deployment ensures all instances share the same timezone configuration.

Applied to files:

modules/pg-simulator/src/main/kotlin/com/loopers/PaymentGatewayApplication.kt
modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/TransactionKeyGenerator.kt
apps/commerce-api/src/main/java/com/loopers/CommerceApiApplication.java
apps/commerce-streamer/src/main/java/com/loopers/CommerceStreamerApplication.java

📚 Learning: 2025-12-07T15:47:18.277Z

Learnt from: toongri
Repo: Loopers-dev-lab/loopers-spring-kotlin-template PR: 52
File: apps/commerce-api/src/main/kotlin/com/loopers/infrastructure/payment/PgFeignConfig.kt:0-0
Timestamp: 2025-12-07T15:47:18.277Z
Learning: In Spring Cloud OpenFeign, configuration classes specified in FeignClient(configuration = ...) do NOT need the Configuration annotation. Spring Cloud OpenFeign creates a separate ApplicationContext for each named client and directly instantiates Bean methods from the configuration class. Adding Configuration would cause the class to be registered globally via ComponentScan, making the configuration apply to ALL Feign clients instead of just the specific client, which is usually undesirable.

Applied to files:

apps/commerce-api/src/main/java/com/loopers/infrastructure/dataplatform/DataPlatformClientConfig.java
apps/commerce-api/src/main/java/com/loopers/CommerceApiApplication.java

🧬 Code graph analysis (19)

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingFacade.java (2)

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java (1)

Slf4j (17-129)

apps/commerce-api/src/main/java/com/loopers/application/product/ProductService.java (1)

Service (19-100)

apps/commerce-api/src/test/java/com/loopers/interfaces/api/ExampleV1ApiE2ETest.java (1)

apps/commerce-api/src/main/java/com/loopers/interfaces/api/example/ExampleV1Dto.java (1)

ExampleV1Dto (5-15)

apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingAggregator.java (1)

modules/pg-simulator/src/main/kotlin/com/loopers/interfaces/api/ApiControllerAdvice.kt (1)

log (18-115)

apps/commerce-api/src/main/java/com/loopers/application/product/ProductCacheService.java (1)

apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java (1)

Slf4j (31-169)

apps/commerce-streamer/src/main/java/com/loopers/application/inbox/EventInboxService.java (3)

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java (1)

Slf4j (24-172)

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java (1)

Slf4j (25-200)

apps/commerce-streamer/src/main/java/com/loopers/application/dlq/DeadLetterQueueService.java (1)

Slf4j (14-49)

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/inbox/EventInboxRepositoryImpl.java (2)

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/dlq/DeadLetterQueueRepositoryImpl.java (1)

Repository (11-21)

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsRepositoryImpl.java (1)

Repository (12-32)

apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/ConsumerSmokeTest.java (2)

apps/commerce-streamer/src/test/java/com/loopers/application/inbox/EventInboxServiceTest.java (1)

SpringBootTest (14-70)

apps/commerce-streamer/src/test/java/com/loopers/application/metrics/ProductMetricsServiceTest.java (1)

SpringBootTest (16-93)

apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1Controller.java (1)

apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1Dto.java (1)

ProductV1Dto (10-90)

apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetricsRepository.java (1)

apps/commerce-api/src/main/java/com/loopers/domain/metrics/product/ProductMetricsRepository.java (1)

ProductMetricsRepository (9-15)

apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingApi.java (2)

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingFacade.java (1)

lombok (81-92)

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java (1)

lombok (122-128)

apps/commerce-streamer/src/test/java/com/loopers/application/metrics/ProductMetricsServiceTest.java (2)

apps/commerce-streamer/src/test/java/com/loopers/application/inbox/EventInboxServiceTest.java (1)

SpringBootTest (14-70)

apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/ConsumerSmokeTest.java (1)

SpringBootTest (23-51)

modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment1_AutoCommitTest.java (4)

modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment2_OffsetResetTest.java (1)

DisplayName (30-238)

modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment3_PollIntervalTest.java (1)

DisplayName (32-241)

modules/kafka/src/test/java/com/loopers/kafka/learning/Experiment4_BatchSizeTest.java (1)

DisplayName (30-357)

modules/pg-simulator/src/main/kotlin/com/loopers/interfaces/api/ApiControllerAdvice.kt (1)

log (18-115)

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsJpaRepository.java (3)

apps/commerce-api/src/main/java/com/loopers/infrastructure/metrics/product/ProductMetricsJpaRepository.java (1)

ProductMetricsJpaRepository (8-10)

apps/commerce-api/src/main/java/com/loopers/infrastructure/metrics/product/ProductMetricsRepositoryImpl.java (1)

RequiredArgsConstructor (13-32)

apps/commerce-api/src/main/java/com/loopers/domain/metrics/product/ProductMetricsRepository.java (1)

ProductMetricsRepository (9-15)

apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java (4)

apps/commerce-api/src/main/java/com/loopers/domain/example/ExampleModel.java (1)

Entity (9-44)

apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueue.java (1)

Getter (18-64)

apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInbox.java (1)

Getter (18-55)

modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/Payment.kt (1)

name (8-81)

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsRepositoryImpl.java (3)

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/dlq/DeadLetterQueueRepositoryImpl.java (1)

Repository (11-21)

apps/commerce-streamer/src/main/java/com/loopers/infrastructure/inbox/EventInboxRepositoryImpl.java (1)

Repository (11-31)

apps/commerce-api/src/main/java/com/loopers/infrastructure/metrics/product/ProductMetricsRepositoryImpl.java (1)

RequiredArgsConstructor (13-32)

apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInbox.java (4)

apps/commerce-api/src/main/java/com/loopers/domain/example/ExampleModel.java (1)

Entity (9-44)

apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueue.java (1)

Getter (18-64)

apps/commerce-streamer/src/main/java/com/loopers/domain/metrics/ProductMetrics.java (1)

Getter (23-115)

modules/pg-simulator/src/main/kotlin/com/loopers/domain/payment/Payment.kt (1)

name (8-81)

apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingScheduler.java (2)

apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingKey.java (1)

RankingKey (10-71)

apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingScore.java (1)

RankingScore (7-65)

apps/commerce-streamer/src/main/java/com/loopers/domain/dlq/DeadLetterQueue.java (1)

apps/commerce-streamer/src/main/java/com/loopers/domain/inbox/EventInbox.java (1)

Getter (18-55)

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java (4)

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingFacade.java (2)

lombok (81-92)

Slf4j (18-93)

apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1Controller.java (1)

RequiredArgsConstructor (22-108)

apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingAggregator.java (1)

Slf4j (16-131)

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/CatalogEventConsumer.java (1)

Slf4j (24-172)

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java

+    private String getTopicByAggregateType(String aggregateType) {
+        return switch (aggregateType.toUpperCase()) {
+            case "ORDER", "PAYMENT" -> orderEventsTopic;
+            case "PRODUCT", "LIKE" -> catalogEventsTopic;
+            default -> throw new IllegalArgumentException("알 수 없는 AggregateType: " + aggregateType);
+        };
+    }


⚠️ Potential issue | 🟡 Minor

Null 체크 누락

aggregateType이 null인 경우 toUpperCase() 호출 시 NullPointerException이 발생합니다. 방어적으로 null 체크를 추가하거나, EventOutbox에서 aggregateType이 항상 non-null임을 보장하는지 확인하세요.

🔎 제안: null 체크 추가

private String getTopicByAggregateType(String aggregateType) { + if (aggregateType == null) { + throw new IllegalArgumentException("AggregateType은 null일 수 없습니다"); + } return switch (aggregateType.toUpperCase()) {

🤖 Prompt for AI Agents

In apps/commerce-api/src/main/java/com/loopers/application/kafka/EventKafkaProducer.java around lines 63-69, the method calls aggregateType.toUpperCase() without null-checking which causes NullPointerException when aggregateType is null; add a defensive null check at the top (e.g., if (aggregateType == null) throw new IllegalArgumentException("aggregateType must not be null") or use Objects.requireNonNull with a clear message) and then proceed to use aggregateType.toUpperCase(Locale.ROOT) (or toUpperCase()) for the switch; ensure the exception message is descriptive so callers know the contract.

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-api/src/main/java/com/loopers/application/order/OrderFacade.java

+            // 재고 소진 시 캐시 갱신
+            if (product.getStock() == 0) {
+                log.info("재고 소진 - 캐시 갱신 - productId: {}", product.getId());
+                productCacheService.evictCache(product.getId());
+            }


⚠️ Potential issue | 🔴 Critical

트랜잭션 커밋 전 캐시 삭제로 인한 데이터 정합성 문제

캐시 삭제가 트랜잭션 커밋 전에 동기적으로 실행되어 다음 문제가 발생할 수 있습니다:

롤백 시 불일치: 트랜잭션이 롤백되어도 캐시는 이미 삭제되어 다음 조회 시 DB에서 잘못된 데이터를 가져옵니다.

성능 영향: 동기 캐시 삭제가 트랜잭션 시간을 늘려 락 홀딩 시간이 증가합니다.

권장 해결 방안:

@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)를 사용하여 트랜잭션 커밋 후 캐시를 삭제

또는 비동기 이벤트를 발행하여 캐시 삭제 처리

🔎 제안하는 수정 (이벤트 기반 접근)

도메인 이벤트를 추가하고 이벤트 리스너에서 캐시 삭제:

// 재고 소진 시 이벤트 발행 if (product.getStock() == 0) { log.info("재고 소진 - productId: {}", product.getId()); // 도메인 이벤트 발행 (예: ProductStockDepletedEvent) }

별도 이벤트 리스너 클래스:

@Component public class ProductCacheEventListener { private final ProductCacheService productCacheService; @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT) public void handleStockDepleted(ProductStockDepletedEvent event) { productCacheService.evictCache(event.getProductId()); } }

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java

        try {
-            // 이벤트 타입에 따라 실제 이벤트 객체로 변환
-            Object event = deserializeEvent(outbox);
-
-            // Spring Event 발행
-            eventPublisher.publishEvent(event);
-
-            // 발행 성공 표시
-            outbox.markAsPublished();
-            outboxRepository.save(outbox);
-
-            log.info("Outbox 이벤트 발행 완료 - id: {}, type: {}",
-                outbox.getId(), outbox.getEventType());
+            // Kafka로 발행
+            kafkaProducer.publish(outbox)
+                .thenAccept(result -> {
+                    // 발행 성공 시 Outbox 상태 업데이트
+                    outbox.markAsPublished();
+                    outboxRepository.save(outbox);
+
+                    log.info("Outbox → Kafka 발행 완료 - outboxId: {}, eventType: {}, offset: {}",
+                        outbox.getId(),
+                        outbox.getEventType(),
+                        result.getRecordMetadata().offset());
+                })
+                .exceptionally(ex -> {
+                    // 발행 실패 시 Outbox 상태 업데이트
+                    outbox.markAsFailed(ex.getMessage());
+                    outboxRepository.save(outbox);
+
+                    log.error("Outbox → Kafka 발행 실패 - outboxId: {}, error: {}",
+                        outbox.getId(), ex.getMessage(), ex);
+
+                    return null;
+                })
+                .join();  // 동기 대기 (트랜잭션 내에서 완료 보장)


⚠️ Potential issue | 🟠 Major

트랜잭션 내 비동기 콜백 사용 시 주의 필요

thenAccept와 exceptionally 콜백에서 outboxRepository.save(outbox)를 호출하고 있습니다. join()이 동기 대기하므로 콜백은 join() 반환 전에 실행되지만, 콜백이 Kafka producer 스레드에서 실행될 수 있어 현재 트랜잭션 컨텍스트가 전파되지 않을 수 있습니다.

또한, exceptionally에서 예외를 삼키고 null을 반환하므로 외부 catch 블록(lines 91-99)에서 중복으로 상태를 저장하고 예외를 다시 던지는 로직이 실행되지 않습니다.

🔎 제안: 동기 방식으로 리팩토링

@Transactional(propagation = Propagation.REQUIRES_NEW) public void publishEvent(EventOutbox outbox) { try { - // Kafka로 발행 - kafkaProducer.publish(outbox) - .thenAccept(result -> { - // 발행 성공 시 Outbox 상태 업데이트 - outbox.markAsPublished(); - outboxRepository.save(outbox); - - log.info("Outbox → Kafka 발행 완료 - outboxId: {}, eventType: {}, offset: {}", - outbox.getId(), - outbox.getEventType(), - result.getRecordMetadata().offset()); - }) - .exceptionally(ex -> { - // 발행 실패 시 Outbox 상태 업데이트 - outbox.markAsFailed(ex.getMessage()); - outboxRepository.save(outbox); - - log.error("Outbox → Kafka 발행 실패 - outboxId: {}, error: {}", - outbox.getId(), ex.getMessage(), ex); - - return null; - }) - .join(); // 동기 대기 (트랜잭션 내에서 완료 보장) + // Kafka로 발행 (동기 대기) + SendResult<Object, Object> result = kafkaProducer.publish(outbox).join(); + + // 발행 성공 시 Outbox 상태 업데이트 + outbox.markAsPublished(); + outboxRepository.save(outbox); + + log.info("Outbox → Kafka 발행 완료 - outboxId: {}, eventType: {}, offset: {}", + outbox.getId(), + outbox.getEventType(), + result.getRecordMetadata().offset()); } catch (Exception e) {

🤖 Prompt for AI Agents

In apps/commerce-api/src/main/java/com/loopers/application/outbox/OutboxEventService.java around lines 66-89, the current use of thenAccept/exceptionally on the Kafka publish future runs callbacks on the producer thread (losing the transaction context) and swallows exceptions by returning null; change this to a synchronous publish flow that executes in the current thread: call the publish and get its result synchronously (or block and rethrow the exception) so that outboxRepository.save(...) is invoked inside the current transactional context on success or failure, remove repository saves from async callbacks, and ensure exceptions are propagated to the outer catch so the duplicated state-save and rethrow logic there remains correct; keep equivalent info/error logging but perform it in the same thread before committing/rolling back the transaction.

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-api/src/main/java/com/loopers/application/product/ProductService.java

+    /**
+     * 여러 상품 ID로 조회 (랭킹용)
+     */
+    @Transactional(readOnly = true)
+    public List<ProductInfo> findByIds(List<Long> ids) {
+        List<Product> products = productRepository.findByIdIn(ids);
+        // Brand 로딩 및 DTO 변환
+        return products.stream()
+            .map(product -> {
+                product.getBrand().getName();  // Brand 로딩
+                return ProductInfo.from(product);
+            })
+            .toList();
+    }


⚠️ Potential issue | 🟠 Major

반환 순서가 입력 ID 순서와 일치하지 않을 수 있음

findByIdIn은 입력된 ID 순서를 보장하지 않습니다. 랭킹 API에서 상위 랭킹 순서대로 상품을 조회할 때, 반환된 리스트가 랭킹 순서와 다를 수 있습니다.

🔎 순서 보장을 위한 수정 제안

@Transactional(readOnly = true) public List<ProductInfo> findByIds(List<Long> ids) { + if (ids.isEmpty()) { + return List.of(); + } List<Product> products = productRepository.findByIdIn(ids); + // ID 순서대로 정렬하여 랭킹 순서 보장 + Map<Long, Product> productMap = products.stream() + .collect(Collectors.toMap(Product::getId, Function.identity())); + - // Brand 로딩 및 DTO 변환 - return products.stream() - .map(product -> { - product.getBrand().getName(); // Brand 로딩 - return ProductInfo.from(product); - }) - .toList(); + return ids.stream() + .map(productMap::get) + .filter(Objects::nonNull) + .map(product -> { + product.getBrand().getName(); // Brand 로딩 + return ProductInfo.from(product); + }) + .toList(); }

📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change

/**

* 여러 상품 ID로 조회 (랭킹용)

*/

@Transactional(readOnly = true)

public List<ProductInfo> findByIds(List<Long> ids) {

List<Product> products = productRepository.findByIdIn(ids);

// Brand 로딩 및 DTO 변환

return products.stream()

.map(product -> {

product.getBrand().getName(); // Brand 로딩

return ProductInfo.from(product);

})

.toList();

}

/**

* 여러 상품 ID로 조회 (랭킹용)

*/

@Transactional(readOnly = true)

public List<ProductInfo> findByIds(List<Long> ids) {

if (ids.isEmpty()) {

return List.of();

}

List<Product> products = productRepository.findByIdIn(ids);

// ID 순서대로 정렬하여 랭킹 순서 보장

Map<Long, Product> productMap = products.stream()

.collect(Collectors.toMap(Product::getId, Function.identity()));

return ids.stream()

.map(productMap::get)

.filter(Objects::nonNull)

.map(product -> {

product.getBrand().getName(); // Brand 로딩

return ProductInfo.from(product);

})

.toList();

}

🤖 Prompt for AI Agents

In apps/commerce-api/src/main/java/com/loopers/application/product/ProductService.java around lines 76 to 89, the current findByIds(List<Long> ids) uses productRepository.findByIdIn(ids) which does not preserve the input ID order; change the method to build a Map<Long,Product> from the repository result (keyed by product.getId()), then iterate the original ids list to produce the returned List<ProductInfo> in the same order (skipping or handling missing ids as appropriate); ensure you still trigger brand loading for each Product before converting to ProductInfo (or update the repo to use a fetch-join so brand is preloaded) so the DTO conversion remains correct.

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java

+    public List<RankingItem> getDailyRanking(String date, int page, int size) {
+        String key = DAILY_PREFIX + date;
+        return getRanking(key, page, size);
+    }


⚠️ Potential issue | 🟠 Major

🧩 Analysis chain

🏁 Script executed:

#!/bin/bash # Search for RankingKey class definition find . -name "RankingKey.java" -type f

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 169

🏁 Script executed:

#!/bin/bash # Search for DAILY_PREFIX usage rg -n "DAILY_PREFIX" --type=java -B 2 -A 2

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 3855

🏁 Script executed:

#!/bin/bash # Search for dailyToday method and RankingKey usage rg -n "dailyToday\|RankingKey" --type=java -B 1 -A 1

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 70

🏁 Script executed:

#!/bin/bash # Search for RankingAggregator class find . -name "RankingAggregator.java" -type f

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 181

🏁 Script executed:

#!/bin/bash # Search for ranking:all: pattern rg -n "ranking:all:" --type=java

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 502

🏁 Script executed:

#!/bin/bash # Read full RankingKey class cat apps/commerce-streamer/src/main/java/com/loopers/domain/ranking/RankingKey.java

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 1864

🏁 Script executed:

#!/bin/bash # Read RankingAggregator class to see how it uses keys cat apps/commerce-streamer/src/main/java/com/loopers/application/ranking/RankingAggregator.java

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 4303

🏁 Script executed:

#!/bin/bash # Also check RankingService for complete context cat apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java

Repository: Loopers-dev-lab/loopers-spring-java-template

Length of output: 3826

RankingService를 RankingKey를 통해 일관되게 리팩토링 필요

RankingService가 DAILY_PREFIX를 중복 정의하고 키를 수동으로 구성하는 반면, RankingAggregator는 RankingKey.dailyToday()를 사용합니다. 더 심각하게는 RankingService.getDailyRanking(String date, ...)이 날짜 형식 검증 없이 직접 문자열을 연결하므로, 잘못된 형식의 date가 전달되면 RankingAggregator가 생성한 키와 일치하지 않습니다.

RankingKey.daily(String dateString) 메서드를 활용하여 날짜 파싱과 키 생성을 중앙화하세요 (라인 36-39, 56-59, 76-77).

🤖 Prompt for AI Agents

In apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java around lines 36-39, 56-59 and 76-77, the service builds daily ranking keys by concatenating DAILY_PREFIX + date (and repeats similar manual key construction), which bypasses date validation and causes mismatches with RankingAggregator; replace those manual constructions to call RankingKey.daily(date) (or RankingKey.dailyToday() where appropriate) so key creation and date parsing/validation are centralized in RankingKey, updating all uses in the listed lines to accept/propagate the RankingKey result instead of assembling raw strings.

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java

+import com.loopers.application.inbox.EventInboxService;
+import com.loopers.application.metrics.ProductMetricsService;
+import com.loopers.application.ranking.RankingAggregator;
+import com.loopers.confg.kafka.KafkaConfig;


⚠️ Potential issue | 🟡 Minor

패키지 경로 오타

confg는 오타입니다. config로 수정해야 합니다.

-import com.loopers.confg.kafka.KafkaConfig; +import com.loopers.config.kafka.KafkaConfig;

📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change

import com.loopers.confg.kafka.KafkaConfig;

import com.loopers.config.kafka.KafkaConfig;

🤖 Prompt for AI Agents

In apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java around line 8, the import package name has a typo: "com.loopers.confg.kafka.KafkaConfig" should be "com.loopers.config.kafka.KafkaConfig"; update the import to the correct package name and fix any other occurrences/usages in this file (and related files) so they reference com.loopers.config.kafka.KafkaConfig.

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java

+    @Transactional
+    protected boolean processEvent(ConsumerRecord<Object, Object> record) throws Exception {


⚠️ Potential issue | 🟠 Major

@Transactional이 프록시 경계 내에서 동작하지 않을 수 있음

processEvent는 protected 메서드이며, 동일 클래스 내의 consumeOrderEvents에서 직접 호출됩니다. Spring AOP 프록시는 내부 호출에서는 @Transactional을 인터셉트하지 않으므로 트랜잭션이 적용되지 않을 수 있습니다.

해결 방안:

processEvent를 별도의 서비스 클래스로 추출하여 주입

또는 consumeOrderEvents 전체를 @Transactional로 감싸기 (배치 처리에 따른 트레이드오프 고려)

🤖 Prompt for AI Agents

In apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java around lines 81-82, the @Transactional annotation on the protected method processEvent will not be applied when called directly from consumeOrderEvents due to Spring proxy internal-call limitations; fix by either extracting the processing logic into a new @Service bean with a public method (move processEvent there, inject that service into OrderEventConsumer and call the service method so the transaction proxy is applied) or by moving @Transactional to consumeOrderEvents itself (annotate consumeOrderEvents as @Transactional, ensuring you accept the transactional scope/behavior implications for the whole consumption loop).

coderabbitai · 2025-12-25T15:34:30Z

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java

+
+            // 랭킹 점수 반영 (단가 계산)
+            int unitPrice = amount.divide(new BigDecimal(quantity), 0, BigDecimal.ROUND_HALF_UP).intValue();
+            rankingAggregator.incrementOrderScore(productId, unitPrice, quantity);


⚠️ Potential issue | 🟡 Minor

Deprecated API 사용: BigDecimal.ROUND_HALF_UP

BigDecimal.ROUND_HALF_UP은 Java 9부터 deprecated입니다. RoundingMode.HALF_UP을 사용하세요.

🔎 수정 제안

+import java.math.RoundingMode; ... - int unitPrice = amount.divide(new BigDecimal(quantity), 0, BigDecimal.ROUND_HALF_UP).intValue(); + int unitPrice = amount.divide(new BigDecimal(quantity), 0, RoundingMode.HALF_UP).intValue();

📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change

// 랭킹 점수 반영 (단가 계산)

int unitPrice = amount.divide(new BigDecimal(quantity), 0, BigDecimal.ROUND_HALF_UP).intValue();

rankingAggregator.incrementOrderScore(productId, unitPrice, quantity);

// 랭킹 점수 반영 (단가 계산)

int unitPrice = amount.divide(new BigDecimal(quantity), 0, RoundingMode.HALF_UP).intValue();

rankingAggregator.incrementOrderScore(productId, unitPrice, quantity);

🤖 Prompt for AI Agents

In apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/OrderEventConsumer.java around lines 156-159, replace the deprecated BigDecimal.ROUND_HALF_UP with java.math.RoundingMode.HALF_UP when calling BigDecimal.divide (i.e., use RoundingMode.HALF_UP as the roundingMode argument), and add or update the import for java.math.RoundingMode; keep the same scale (0) and int conversion logic otherwise.

coderabbitai · 2025-12-25T15:34:30Z

.../commerce-streamer/src/test/java/com/loopers/interfaces/consumer/OrderEventConsumerTest.java

+        @Test
+        @DisplayName("주문 생성 이벤트를 받으면 ProductMetrics의 주문 수와 판매 금액을 증가시킨다")
+        void incrementOrderCountAndSalesAmount() throws Exception {
+            // Given: 주문 생성 이벤트
+            Long productId = 1L;
+            int quantity = 3;
+            BigDecimal totalAmount = new BigDecimal("30000");
+
+            String eventId = "order-event-001";
+            Map<String, Object> orderData = new HashMap<>();
+            orderData.put("productId", productId);
+            orderData.put("quantity", quantity);
+            orderData.put("totalAmount", totalAmount);
+
+            Map<String, Object> event = createEvent(eventId, "OrderCreatedEvent", "ORDER", "order-123");
+            event.put("payload", orderData);
+
+            ConsumerRecord<Object, Object> record = createConsumerRecord("order-events", event);
+
+            when(eventInboxService.isDuplicate(eventId)).thenReturn(false);
+
+            // When: Consumer가 이벤트 처리
+            boolean result = orderEventConsumer.processEvent(record);
+
+            // Then: Inbox에 저장하고, 주문 수와 판매 금액 증가
+            assertThat(result).isTrue();
+            verify(eventInboxService).save(eventId, "ORDER", "order-123", "OrderCreatedEvent");
+            verify(productMetricsService).incrementOrderCount(eq(productId), eq(quantity), eq(totalAmount));
+        }


⚠️ Potential issue | 🟡 Minor

RankingAggregator.incrementOrderScore 호출 검증 누락

OrderCreatedEvent 처리 시 rankingAggregator.incrementOrderScore가 호출되어야 하지만, 테스트에서 이를 검증하지 않습니다.

🔎 검증 추가 제안

verify(eventInboxService).save(eventId, "ORDER", "order-123", "OrderCreatedEvent"); verify(productMetricsService).incrementOrderCount(eq(productId), eq(quantity), eq(totalAmount)); + verify(rankingAggregator).incrementOrderScore(eq(productId), anyInt(), eq(quantity));

📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change

@Test

@DisplayName("주문 생성 이벤트를 받으면 ProductMetrics의 주문 수와 판매 금액을 증가시킨다")

void incrementOrderCountAndSalesAmount() throws Exception {

// Given: 주문 생성 이벤트

Long productId = 1L;

int quantity = 3;

BigDecimal totalAmount = new BigDecimal("30000");

String eventId = "order-event-001";

Map<String, Object> orderData = new HashMap<>();

orderData.put("productId", productId);

orderData.put("quantity", quantity);

orderData.put("totalAmount", totalAmount);

Map<String, Object> event = createEvent(eventId, "OrderCreatedEvent", "ORDER", "order-123");

event.put("payload", orderData);

ConsumerRecord<Object, Object> record = createConsumerRecord("order-events", event);

when(eventInboxService.isDuplicate(eventId)).thenReturn(false);

// When: Consumer가 이벤트 처리

boolean result = orderEventConsumer.processEvent(record);

// Then: Inbox에 저장하고, 주문 수와 판매 금액 증가

assertThat(result).isTrue();

verify(eventInboxService).save(eventId, "ORDER", "order-123", "OrderCreatedEvent");

verify(productMetricsService).incrementOrderCount(eq(productId), eq(quantity), eq(totalAmount));

}

@Test

@DisplayName("주문 생성 이벤트를 받으면 ProductMetrics의 주문 수와 판매 금액을 증가시킨다")

void incrementOrderCountAndSalesAmount() throws Exception {

// Given: 주문 생성 이벤트

Long productId = 1L;

int quantity = 3;

BigDecimal totalAmount = new BigDecimal("30000");

String eventId = "order-event-001";

Map<String, Object> orderData = new HashMap<>();

orderData.put("productId", productId);

orderData.put("quantity", quantity);

orderData.put("totalAmount", totalAmount);

Map<String, Object> event = createEvent(eventId, "OrderCreatedEvent", "ORDER", "order-123");

event.put("payload", orderData);

ConsumerRecord<Object, Object> record = createConsumerRecord("order-events", event);

when(eventInboxService.isDuplicate(eventId)).thenReturn(false);

// When: Consumer가 이벤트 처리

boolean result = orderEventConsumer.processEvent(record);

// Then: Inbox에 저장하고, 주문 수와 판매 금액 증가

assertThat(result).isTrue();

verify(eventInboxService).save(eventId, "ORDER", "order-123", "OrderCreatedEvent");

verify(productMetricsService).incrementOrderCount(eq(productId), eq(quantity), eq(totalAmount));

verify(rankingAggregator).incrementOrderScore(eq(productId), anyInt(), eq(quantity));

}

🤖 Prompt for AI Agents

In apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/OrderEventConsumerTest.java around lines 67-95 the test for OrderCreatedEvent misses verification that rankingAggregator.incrementOrderScore is invoked; add a verify call after existing assertions to assert rankingAggregator.incrementOrderScore was called with the expected arguments (at minimum the productId and quantity) using Mockito matchers (e.g., verify(rankingAggregator).incrementOrderScore(eq(productId), eq(quantity))); if the method also accepts totalAmount include eq(totalAmount) as the third argument.

coderabbitai · 2025-12-25T15:34:30Z

modules/kafka/src/test/java/com/loopers/kafka/learning/README.md

+### 3. Consumer Group 관리
+
+```bash
+# Consumer Group 목록
+kafka-consumer-groups.sh --bootstrap-server localhost:19092 --list
+
+# 오프셋 확인
+kafka-consumer-groups.sh --bootstrap-server localhost:19092 \
+  --group learning-group \
+  --describe
+
+# Group 삭제 (재실험 시)
+kafka-consumer-groups.sh --bootstrap-server localhost:19092 \
+  --group learning-group \
+  --delete
+```
+
+---
+
+## 🛠️ 트러블슈팅
+
+### Consumer가 메시지를 못 읽어요
+
+**확인 사항:**
+1. Kafka 실행 중? `docker ps | grep kafka`
+2. 토픽 생성됨? `kafka-topics.sh --list`
+3. `auto.offset.reset` 설정 확인
+
+**해결:**
+```bash
+# Consumer Group 리셋
+kafka-consumer-groups.sh --bootstrap-server localhost:19092 \
+  --group 그룹명 --reset-offsets --to-earliest --topic learning-topic --execute
+```
+
+### 테스트가 멈춰요
+
+**원인:** Kafka 연결 실패
+
+**해결:**
+```bash
+docker-compose restart kafka
+```
+


⚠️ Potential issue | 🟡 Minor

Consumer Group 관리 및 트러블슈팅 명령어가 EmbeddedKafka 환경과 불일치합니다.

README의 주요 내용은 EmbeddedKafka를 사용하여 Docker 없이 테스트를 실행하는 것을 강조하고 있지만, Consumer Group 관리 (Line 166-181)와 트러블슈팅 섹션 (Line 185-209)에서 제공하는 kafka-consumer-groups.sh 및 kafka-topics.sh 명령어는 외부 Kafka 브로커에 접근하는 것을 전제로 합니다.

EmbeddedKafka는 테스트 실행 중에만 존재하며 일반적인 Kafka CLI 도구로 직접 접근할 수 없어 해당 명령어들이 작동하지 않습니다. 이는 학습자에게 혼란을 줄 수 있습니다.

다음 중 하나를 권장합니다:

해당 섹션에 "Docker Kafka를 사용하는 경우에만 적용 가능" 주석 추가

EmbeddedKafka 환경에서는 테스트 코드 내에서 직접 디버깅하는 것을 권장하는 내용으로 수정

rkdalsdn94 self-assigned this Dec 25, 2025

rkdalsdn94 added the enhancement New feature or request label Dec 25, 2025

rkdalsdn94 added 3 commits December 26, 2025 00:29

test: Consumer 테스트에 RankingAggregator Mock 추가

0ac72f7

Consumer에 RankingAggregator 의존성이 추가되면서 테스트 코드도 함께 수정 필요 - CatalogEventConsumerTest: RankingAggregator Mock 추가 - OrderEventConsumerTest: RankingAggregator Mock 추가

coderabbitai bot reviewed Dec 25, 2025

View reviewed changes

chore: trigger GitHub conflict check update

d1fb5f4

rkdalsdn94 closed this Dec 25, 2025

rkdalsdn94 reopened this Dec 25, 2025

rkdalsdn94 force-pushed the rkdalsdn94 branch from f6c8979 to d1fb5f4 Compare December 25, 2025 15:47

rkdalsdn94 merged commit af900e1 into Loopers-dev-lab:rkdalsdn94 Dec 30, 2025
2 checks passed

	import com.loopers.confg.kafka.KafkaConfig;
	import com.loopers.config.kafka.KafkaConfig;

		@Transactional
		protected boolean processEvent(ConsumerRecord<Object, Object> record) throws Exception {

[volume-9] Product Ranking with Redis #212

[volume-9] Product Ranking with Redis #212

Uh oh!

Conversation

rkdalsdn94 commented Dec 25, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

📌 Summary

Redis ZSET을 활용한 실시간 랭킹 시스템을 구현했습니다.

주요 구현 사항

💬 Review Points

콜드 스타트 관련 질문입니다.

키 설계에 관한 고민입니다.

배치 처리 크기를 어떻게 하면 좋을까요?

✅ Checklist

📈 Ranking Consumer

⚾ Ranking API

Summary by CodeRabbit

릴리스 노트

Uh oh!

coderabbitai bot commented Dec 25, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Walkthrough

Changes

Sequence Diagram(s)

Estimated code review effort

Possibly related PRs

Poem

Pre-merge checks and finishing touches

Uh oh!

coderabbitai bot left a comment

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

coderabbitai bot Dec 25, 2025

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

1 participant

rkdalsdn94 commented Dec 25, 2025 •

edited

Loading

coderabbitai bot commented Dec 25, 2025 •

edited

Loading