diff --git a/.claude/settings.local.json b/.claude/settings.local.json index c49d02b..2e0a79d 100644 --- a/.claude/settings.local.json +++ b/.claude/settings.local.json @@ -19,7 +19,8 @@ "Bash(netstat:*)", "Bash(findstr:*)", "Bash(./gradlew analytics-service:compileJava:*)", - "Bash(python -m json.tool:*)" + "Bash(python -m json.tool:*)", + "Bash(powershell:*)" ], "deny": [], "ask": [] diff --git a/.gradle/8.10/executionHistory/executionHistory.bin b/.gradle/8.10/executionHistory/executionHistory.bin index cf52da0..2615054 100644 Binary files a/.gradle/8.10/executionHistory/executionHistory.bin and b/.gradle/8.10/executionHistory/executionHistory.bin differ diff --git a/.gradle/8.10/executionHistory/executionHistory.lock b/.gradle/8.10/executionHistory/executionHistory.lock index 9fc5cce..6eb6217 100644 Binary files a/.gradle/8.10/executionHistory/executionHistory.lock and b/.gradle/8.10/executionHistory/executionHistory.lock differ diff --git a/.gradle/8.10/fileHashes/fileHashes.bin b/.gradle/8.10/fileHashes/fileHashes.bin index 300d2d1..d1fba3b 100644 Binary files a/.gradle/8.10/fileHashes/fileHashes.bin and b/.gradle/8.10/fileHashes/fileHashes.bin differ diff --git a/.gradle/8.10/fileHashes/fileHashes.lock b/.gradle/8.10/fileHashes/fileHashes.lock index 44aad75..15d9991 100644 Binary files a/.gradle/8.10/fileHashes/fileHashes.lock and b/.gradle/8.10/fileHashes/fileHashes.lock differ diff --git a/.gradle/8.10/fileHashes/resourceHashesCache.bin b/.gradle/8.10/fileHashes/resourceHashesCache.bin index 7fcad2b..9b44346 100644 Binary files a/.gradle/8.10/fileHashes/resourceHashesCache.bin and b/.gradle/8.10/fileHashes/resourceHashesCache.bin differ diff --git a/.gradle/buildOutputCleanup/buildOutputCleanup.lock b/.gradle/buildOutputCleanup/buildOutputCleanup.lock index 5885331..7594446 100644 Binary files a/.gradle/buildOutputCleanup/buildOutputCleanup.lock and b/.gradle/buildOutputCleanup/buildOutputCleanup.lock differ diff --git a/analytics-service/src/main/java/com/kt/event/analytics/config/SampleDataLoader.java b/analytics-service/src/main/java/com/kt/event/analytics/config/SampleDataLoader.java index 7461258..a9ce7b5 100644 --- a/analytics-service/src/main/java/com/kt/event/analytics/config/SampleDataLoader.java +++ b/analytics-service/src/main/java/com/kt/event/analytics/config/SampleDataLoader.java @@ -95,7 +95,7 @@ public class SampleDataLoader implements ApplicationRunner { log.info("발행된 이벤트:"); log.info(" - EventCreated: 3건"); log.info(" - DistributionCompleted: 12건 (3 이벤트 × 4 채널)"); - log.info(" - ParticipantRegistered: 약 27,610건"); + log.info(" - ParticipantRegistered: 180건 (MVP 테스트용)"); log.info("========================================"); // Consumer 처리 대기 (3초) @@ -232,7 +232,7 @@ public class SampleDataLoader implements ApplicationRunner { */ private void publishParticipantRegisteredEvents() throws Exception { String[] eventIds = {"evt_2025012301", "evt_2025020101", "evt_2025011501"}; - int[] totalParticipants = {15420, 8950, 3240}; + int[] totalParticipants = {100, 50, 30}; // MVP 테스트용 샘플 데이터 (총 180명) String[] channels = {"우리동네TV", "지니TV", "링고비즈", "SNS"}; int totalPublished = 0; @@ -254,13 +254,6 @@ public class SampleDataLoader implements ApplicationRunner { publishEvent(PARTICIPANT_REGISTERED_TOPIC, event); totalPublished++; - - // 1000명마다 로그 출력 및 짧은 대기 (Kafka 부하 방지) - if (totalPublished % 1000 == 0) { - log.info(" ⏳ ParticipantRegistered 발행 진행 중... ({}/{})", totalPublished, - totalParticipants[0] + totalParticipants[1] + totalParticipants[2]); - Thread.sleep(100); // 0.1초 대기 - } } }