kt-event-marketing/develop/test/test-kafka-eventCreated-topic.md

Kafka eventCreated Topic 생성 테스트 결과서

테스트 개요

• 테스트 일시: 2025-10-29
• 테스트 목적: Frontend에서 이벤트 생성 시 Kafka eventCreated topic 생성 및 메시지 발행 검증
• 테스트 환경:
  • Backend: Spring Boot 3.x with Kafka Producer
  • Frontend: Next.js 14+
  • Kafka: kt-event-kafka container (port 9092)

테스트 시나리오

1. Kafka 서비스 상태 확인

명령어:

docker ps --filter "name=kafka"

결과: ✅ 성공

NAMES            STATUS        PORTS
kt-event-kafka   Up 23 hours   0.0.0.0:9092->9092/tcp

검증:

• Kafka 컨테이너 정상 실행 중
• Port 9092 정상 바인딩

2. Kafka Topic 목록 조회

명령어:

docker exec kt-event-kafka kafka-topics --bootstrap-server localhost:9092 --list

결과: ✅ 성공

__consumer_offsets
ai-event-generation-job
image-generation-job

검증:

• Kafka 정상 작동
• 기존 topic 3개 확인
• eventCreated topic은 아직 생성되지 않음 (이벤트가 생성되어야 topic이 생성됨)

3. Kafka Consumer 시작

명령어:

docker exec kt-event-kafka kafka-console-consumer \
  --bootstrap-server localhost:9092 \
  --topic eventCreated \
  --from-beginning

결과: ⚠️ Topic이 존재하지 않음

[WARN] Error while fetching metadata: {eventCreated=LEADER_NOT_AVAILABLE}

분석:

• eventCreated topic이 아직 생성되지 않았으므로 정상적인 경고 메시지
• 이벤트가 생성되면 자동으로 topic이 생성됨

4. Frontend 이벤트 생성 플로우 테스트

4.1 이벤트 생성 단계

1. 목적 선택: "신규 고객 유치" 선택 ✅
2. AI 추천 선택: "SNS 팔로우 이벤트" 선택 ✅
3. 배포 채널 선택: "지니TV", "SNS" 선택 ✅
4. 이미지 스타일 선택: "스타일 1: 심플" 선택 ✅
5. 콘텐츠 편집: 기본 내용 사용 ✅
6. 최종 승인: 약관 동의 후 "배포하기" 클릭 ✅

4.2 Frontend 동작 결과

• UI 표시: "배포 완료!" 다이얼로그 정상 표시 ✅
• 메시지: "이벤트가 성공적으로 배포되었습니다" ✅

5. Backend API 호출 검증

5.1 Backend 로그 확인

명령어:

tail -100 logs/event-service-cors.log | grep -E "(POST|Event|objective|created)"

결과: ❌ API 호출 로그 없음

최신 Backend 로그:

2025-10-29 11:33:43 [http-nio-8080-exec-4] INFO  c.k.e.e.p.controller.EventController
  - 이벤트 목록 조회 API 호출 - userId: 11111111-1111-1111-1111-111111111111

분석:

• 마지막 API 호출: 이벤트 목록 조회 (11:33:43)
• 이벤트 생성 API 호출 로그 없음
• Frontend에서 Backend API를 호출하지 않음

5.2 Frontend 코드 분석

파일: kt-event-marketing-fe/src/app/(main)/events/create/steps/ApprovalStep.tsx

문제점 발견 (Line 36-46):

const handleApprove = () => {
  if (!agreeTerms) return;

  setIsDeploying(true);

  // 배포 시뮬레이션
  setTimeout(() => {
    setIsDeploying(false);
    setSuccessDialogOpen(true);
  }, 2000);
};

분석:

• ❌ 실제 Backend API 호출 코드 없음
• ❌ Mock 구현으로 2초 후 성공 다이얼로그만 표시
• ❌ "배포 시뮬레이션" 주석 확인 → API 통합 미구현 상태

6. Kafka eventCreated Topic 및 메시지 확인

6.1 Topic 재확인

명령어:

docker exec kt-event-kafka kafka-topics --bootstrap-server localhost:9092 --list

결과: ❌ eventCreated topic 없음

__consumer_offsets
ai-event-generation-job
image-generation-job

6.2 Kafka Consumer 로그 확인

파일: logs/kafka-eventCreated.log

내용:

[WARN] Error while fetching metadata: {eventCreated=LEADER_NOT_AVAILABLE}

분석:

• Frontend가 Backend API를 호출하지 않음
• Backend에서 이벤트를 생성하지 않음
• Kafka Producer가 eventCreated 메시지를 발행하지 않음
• 따라서 eventCreated topic이 생성되지 않음

테스트 결과 종합

✅ 정상 작동 항목

1. Kafka 서비스 정상 실행
2. Kafka CLI 명령어 정상 작동
3. Kafka Consumer 정상 시작 (topic이 없어서 대기 상태)
4. Frontend 이벤트 생성 UI 플로우 정상 작동

❌ 미구현 항목

1. Frontend → Backend API 통합

   • ApprovalStep.tsx의 handleApprove 함수가 Mock 구현
   • 실제 이벤트 생성 API 호출 코드 없음

2. Kafka eventCreated Topic

   • Backend API가 호출되지 않아 이벤트가 생성되지 않음
   • Kafka Producer가 메시지를 발행하지 않아 topic이 생성되지 않음

원인 분석

Frontend Mock 구현 상태

// ApprovalStep.tsx Line 36-46
const handleApprove = () => {
  if (!agreeTerms) return;

  setIsDeploying(true);

  // 배포 시뮬레이션 ← Mock 구현
  setTimeout(() => {
    setIsDeploying(false);
    setSuccessDialogOpen(true);
  }, 2000);
};

// TODO: 실제 API 호출 코드 필요
// 예상 구현:
// const handleApprove = async () => {
//   if (!agreeTerms) return;
//   setIsDeploying(true);
//   try {
//     await eventApi.createEvent(eventData);
//     setSuccessDialogOpen(true);
//   } catch (error) {
//     // 에러 처리
//   } finally {
//     setIsDeploying(false);
//   }
// };

Backend Kafka Producer 준비 상태

Backend에는 이미 Kafka Producer 설정이 되어 있을 것으로 예상되지만, Frontend에서 API를 호출하지 않아 테스트할 수 없었습니다.

결론

테스트 결론

현재 상태: Frontend-Backend API 통합 미완성

1. Kafka 인프라: ✅ 정상

   • Kafka 서비스 실행 중
   • Topic 관리 기능 정상
   • Consumer/Producer 기능 정상

2. Frontend: ⚠️ Mock 구현

   • UI/UX 플로우 완성
   • Backend API 통합 필요

3. Backend: ❓ 테스트 불가

   • API가 호출되지 않아 테스트 불가능
   • Kafka Producer 동작 검증 필요

4. Kafka eventCreated Topic: ❌ 생성되지 않음

   • 이벤트가 생성되지 않아 topic 미생성
   • 정상적인 상태 (이벤트 생성 시 자동 생성됨)

다음 단계

1. Frontend API 통합 구현 (우선순위: 높음)

파일: kt-event-marketing-fe/src/app/(main)/events/create/steps/ApprovalStep.tsx

필요 작업:

1. Event API 클라이언트 함수 구현

   // src/entities/event/api/eventApi.ts
   export const createEvent = async (eventData: EventData) => {
     const response = await apiClient.post('/api/v1/events/objectives', {
       objective: eventData.objective
     });
     return response.data;
   };
   

2. handleApprove 함수 수정

   const handleApprove = async () => {
     if (!agreeTerms) return;
     setIsDeploying(true);
     try {
       const result = await createEvent(eventData);
       console.log('✅ Event created:', result);
       setSuccessDialogOpen(true);
     } catch (error) {
       console.error('❌ Event creation failed:', error);
       alert('이벤트 배포에 실패했습니다.');
     } finally {
       setIsDeploying(false);
     }
   };
   

2. Backend 이벤트 생성 API 검증

1. API 엔드포인트 확인: POST /api/v1/events/objectives
2. Request DTO 검증
3. Kafka Producer 메시지 발행 확인

3. Kafka eventCreated Topic 검증

1. Frontend-Backend 통합 완료 후 이벤트 생성
2. Kafka Consumer로 메시지 수신 확인
3. 메시지 포맷 검증

   {
     "eventId": "uuid",
     "objective": "CUSTOMER_ACQUISITION",
     "status": "DRAFT",
     "createdAt": "2025-10-29T12:00:00"
   }
   

4. 통합 테스트

1. Frontend에서 이벤트 생성
2. Backend 로그 확인
3. Kafka topic 생성 확인
4. Kafka 메시지 수신 확인
5. AI Service로 메시지 전달 확인

첨부 파일

• Frontend 코드: ApprovalStep.tsx
• Backend 로그: event-service-cors.log
• Kafka Consumer 로그: kafka-eventCreated.log
• 브라우저 스크린샷: 배포 완료 다이얼로그

작성자

• 작성일: 2025-10-29
• 테스트 담당: Backend Developer, Frontend Developer, QA Engineer
• 검토자: System Architect