From 7b3ca40e226f2ef34dea2327bf4b3ff9898f5a99 Mon Sep 17 00:00:00 2001 From: Hyowon Yang Date: Fri, 24 Oct 2025 15:27:30 +0900 Subject: [PATCH] =?UTF-8?q?=EC=83=98=ED=94=8C=20=EB=8D=B0=EC=9D=B4?= =?UTF-8?q?=ED=84=B0=20=EB=B0=9C=ED=96=89=EB=9F=89=20=EC=B6=95=EC=86=8C=20?= =?UTF-8?q?(=ED=83=80=EC=9E=84=EC=95=84=EC=9B=83=20=EB=B0=A9=EC=A7=80)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - ParticipantRegistered 이벤트: 27,610건 → 180건 - 이벤트별 참여자 수: - 이벤트1: 15,420명 → 100명 - 이벤트2: 8,950명 → 50명 - 이벤트3: 3,240명 → 30명 - Kafka 발행 지연 로직 제거 (불필요) - MVP 테스트에 충분한 데이터 유지 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude --- .claude/settings.local.json | 3 ++- .../executionHistory/executionHistory.bin | Bin 968403 -> 968403 bytes .../executionHistory/executionHistory.lock | Bin 17 -> 17 bytes .gradle/8.10/fileHashes/fileHashes.bin | Bin 29797 -> 29797 bytes .gradle/8.10/fileHashes/fileHashes.lock | Bin 17 -> 17 bytes .../8.10/fileHashes/resourceHashesCache.bin | Bin 23121 -> 23155 bytes .../buildOutputCleanup.lock | Bin 17 -> 17 bytes .../analytics/config/SampleDataLoader.java | 11 ++--------- 8 files changed, 4 insertions(+), 10 deletions(-) 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 cf52da0de94572efc9ef8b22cc6a15fa340cefa6..261505416cedad5373bfe625cfef2274811f3739 100644 GIT binary patch delta 1093 zcmccIYkj%bx?v0Bdw<&$)3S=9ij2hMti-as)U0Cj(lp}=)2e*4N`X!z=c2W$6LY2a zoy%t4o6RqcA+lX3fRTwwK-T@@vc*;_{$0H3{yN0qlJ9i8AjV7q?$5n4gG}aVU4h?1r`=jQj^0`?^5V_k8DIG( z@1MDZx9#H0aIT)`)NS4KI^X;yuF1XZJT-mebmmV2c9RwCzIkk`P&v!}=gtc5nbQrsnLY`) zt$LB<7P4T~J<-!Pd277nwg-M;%Jl9Wc-`T*I z!YZI`70~}7ssDw4c)({7YiToh650+-Ld&JMe_hD;j|U?SO+V<%ad`W&^?ad>5}!|$ z>@C<8wDUlf(Yia|??39g4@z1MVbeFx=S>pWW%z#+gVM{qjDV|MLVwTcPG8W^#eGQ`7EKnMt2+-ZvH|9tf)+Nz3n!%*YE^y|JicZk0u;LCyEc8%IS(K)F*{=^+YBAj|h%r-uA=Ri!)qTSe&vRi9 zIDPh>n7%!Tu~!>i?cVN_%N80RP+(@j(9oVA%m~Cx+w+5&H?Y~|Rpq4?rJ9J#_ni9+niQ?YB(WA8~GfBgHbCb-JA|dsX|NmCQiQ z0>rG_|Ey$-^>7O^WMBv~oQ)^EnGUxzIfK)Zoozj%K;*M%!GkKVT*N;5OiIv3xTFfcgW5|Dbi=lB~9?)SUS-P+yLo)kLW zu$$?VfPwJL_~r`dQ#MJ}^!fn8Or_5xLVZxUl#0J^{zR5hy@|?6!ZL%=D0P`#wpQlWgt4Py}KQAm#*O zE+FOxVxH}GzPySV_|n3jP1nDbB{R5Bc*|h0yenAnx2OQR(DVySd0e;0E#YWvOx zz7$pg`Q)8nQr0}&@wJ}&$TfwEBzTh84oniurMG`w$oG#2BTY;{=*w|<`?2+Wp^V}d zTlQVx5$X7oej~i*#H1s(7w>|S%8BV4=JO^CoVyfU{j>BAGe@k>+lJ{ZpQkVA=W*Kp zd?R0{P>hDbt?yYk>utkMHGk3!_c{j52Ft5*a;9=IFfh&%c~(#`*}gz3 zNY?%0vc*;_{$0H3{yN0qk}p{D%J)wUU?3;}r1Xq|geDLxg0KKq9e1W#0wsY!P+;=v z0(I^?)6yV(2BXQ2h3cDG3OyMWelKnOvBK+U$un-L^KQZ4l^_nWehX2lqcK@AR9OB* h$=-rpK|2pr8LhkX{r)3}n*1(^8f}Kn^NWr#0su!lP!j+E delta 229 zcmaF*g7N7K#ti{6%(qiRHwVXD5ti7?&7=8X^SOGry;`c`1_ovf42-ixZWq)~wl9!U zsIb>EmC6ldQJU&yzdm581z7U5%>xE75OA1m=p`(VP0c0Oy>KG+d=BfRFsq$9Qv$L3uGN&UL8;Fwy*00vQko9{|0b2Gl&sQ5#Cqk#eUW=9VJ iAths=q$Cgvg0O(LRY3oTr2ZHF;Q^mTtfkF>f^q<*1sH1p delta 36 scmeyoh4JDR#tkMCj2)XzB{ni{{wFEL&3JL6;t%nS1|Hm-9X$ku02R0mng9R* diff --git a/.gradle/buildOutputCleanup/buildOutputCleanup.lock b/.gradle/buildOutputCleanup/buildOutputCleanup.lock index 5885331a932cfee98354e736fcd4965e2a050256..7594446866dd84d74197f577cad79c8ed3a1aae7 100644 GIT binary patch literal 17 VcmZQ(PG7Ze^~s_h1~6c<1OPL$1cLwo literal 17 VcmZQ(PG7Ze^~s_h1~6cf0{}Ca1ZV&N 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초 대기 - } } }