[HSC-423] user-log publish/admin 전달 비동기 분리 및 executor 계측 분리

src/main/java/site/holliverse/customer/application/usecase/log/AdminLogFeatureDispatchService.java

@@ -0,0 +1,23 @@
+package site.holliverse.customer.application.usecase.log;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Profile;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import site.holliverse.customer.integration.external.AdminLogFeaturesClient;
+
+/**
+ * admin log-feature 별도 executor로 분리
+ */
+@Service
+@Profile("customer")
+@RequiredArgsConstructor
+public class AdminLogFeatureDispatchService {
+
+    private final AdminLogFeaturesClient adminLogFeaturesClient;
+
+    @Async("adminLogFeatureTaskExecutor")
+    public void dispatch(Long memberId, UserLogEventName eventName, String timestamp) {
+        adminLogFeaturesClient.sendLogFeature(memberId, eventName, timestamp);
+    }
+}

src/main/java/site/holliverse/customer/application/usecase/log/UserLogService.java

@@ -11,7 +11,6 @@
 import org.springframework.stereotype.Service;
 
 import com.github.f4b6a3.tsid.Tsid;
-import site.holliverse.customer.integration.external.AdminLogFeaturesClient;
 import site.holliverse.customer.web.dto.log.UserLogRequest;
 import site.holliverse.customer.error.CustomerErrorCode;
 import site.holliverse.customer.error.CustomerException;
@@ -27,7 +26,7 @@ public class UserLogService {
 
     private final KafkaTemplate<String, String> kafkaTemplate;
     private final ObjectMapper objectMapper;
-    private final AdminLogFeaturesClient adminLogFeaturesClient;
+    private final AdminLogFeatureDispatchService adminLogFeatureDispatchService;
     private final CustomerMetrics customerMetrics;
 
     @Value("${app.topic.client-events}")
@@ -121,7 +120,7 @@ private void sendAdminTarget(Long memberId, UserLogRequest request) {
             return;
         }
 
-        adminLogFeaturesClient.sendLogFeature(
+        adminLogFeatureDispatchService.dispatch(
                 memberId,
                 eventName,
                 request.timestamp()

src/main/java/site/holliverse/shared/config/runtime/CustomerRuntimeInfraConfiguration.java

@@ -34,6 +34,18 @@ public ThreadPoolTaskExecutor userLogTaskExecutor() {
         return executor;
     }
 
+    @Bean(name = "adminLogFeatureTaskExecutor")
+    public ThreadPoolTaskExecutor adminLogFeatureTaskExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(4);
+        executor.setMaxPoolSize(16);
+        executor.setQueueCapacity(512);
+        executor.setThreadNamePrefix("admin-log-feature-");
+        executor.setRejectedExecutionHandler(new java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy());
+        executor.initialize();
+        return executor;
+    }
+
     @Bean(name = "recommendationTaskExecutor")
     public ThreadPoolTaskExecutor recommendationTaskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

src/main/java/site/holliverse/shared/monitoring/CustomerMonitoringBinder.java

@@ -16,13 +16,15 @@ public CustomerMonitoringBinder(
             MeterRegistry meterRegistry,
             RecommendationPendingFutureRegistry pendingFutureRegistry,
             @Qualifier("userLogTaskExecutor") ThreadPoolTaskExecutor userLogTaskExecutor,
+            @Qualifier("adminLogFeatureTaskExecutor") ThreadPoolTaskExecutor adminLogFeatureTaskExecutor,
             @Qualifier("recommendationTaskExecutor") ThreadPoolTaskExecutor recommendationTaskExecutor
     ) {
         Gauge.builder("holliverse.recommendation.pending.size", pendingFutureRegistry, RecommendationPendingFutureRegistry::size)
                 .description("Pending recommendation futures waiting for Kafka completion")
                 .register(meterRegistry);
 
         bindExecutorMetrics(meterRegistry, "user-log", userLogTaskExecutor);
+        bindExecutorMetrics(meterRegistry, "admin-log-feature", adminLogFeatureTaskExecutor);
         bindExecutorMetrics(meterRegistry, "recommendation-trigger", recommendationTaskExecutor);
     }