[pinpoint-apm#12244] Add MetricCollectorProperties for configurable cache size

Author: minwoo-jung

metric-module/metric/src/main/java/com/navercorp/pinpoint/metric/collector/MetricAppPropertySources.java

@@ -24,9 +24,11 @@
  */
 
 @PropertySources({
-        @PropertySource(name = "MetricAppPropertySources-KAFKA", value = { MetricAppPropertySources.KAFKA_TOPIC}),
+        @PropertySource(name = "MetricAppPropertySources-CONFIG", value = { MetricAppPropertySources.KAFKA_TOPIC, MetricAppPropertySources.COLLECTOR_CONFIG}),
 })
 public class MetricAppPropertySources {
     public static final String KAFKA_TOPIC = "classpath:pinot-collector/kafka-topic.properties";
 
+    public static final String COLLECTOR_CONFIG = "classpath:pinot-collector/profiles/${pinpoint.profiles.active:release}/collector-metric.properties";
+
 }

metric-module/metric/src/main/java/com/navercorp/pinpoint/metric/collector/MetricCollectorApp.java

@@ -1,6 +1,7 @@
 package com.navercorp.pinpoint.metric.collector;
 
 import com.navercorp.pinpoint.metric.collector.cache.MetricCacheConfiguration;
+import com.navercorp.pinpoint.metric.collector.config.MetricCollectorProperties;
 import com.navercorp.pinpoint.metric.collector.config.MetricKafkaConfiguration;
 import com.navercorp.pinpoint.metric.common.config.MetricCollectorPinotDaoConfiguration;
 import com.navercorp.pinpoint.pinot.config.PinotConfiguration;
@@ -35,7 +36,9 @@
         MetricCacheConfiguration.class,
         PinotConfiguration.class,
         MetricCollectorPinotDaoConfiguration.class,
-        MetricKafkaConfiguration.class
+        MetricKafkaConfiguration.class,
+        MetricCollectorProperties.class
+
 })
 @Profile("metric")
 public class MetricCollectorApp {

metric-module/metric/src/main/java/com/navercorp/pinpoint/metric/collector/cache/MetricCacheConfiguration.java

@@ -17,6 +17,7 @@
 package com.navercorp.pinpoint.metric.collector.cache;
 
 import com.github.benmanes.caffeine.cache.Caffeine;
+import com.navercorp.pinpoint.metric.collector.config.MetricCollectorProperties;
 import org.springframework.cache.CacheManager;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.cache.caffeine.CaffeineCacheManager;
@@ -48,7 +49,7 @@ public CacheManager cacheManager() {
     }
 
     @Bean
-    public CacheManager metricTagCollection() {
+    public CacheManager metricTagCollection(MetricCollectorProperties metricCollectorProperties) {
         CaffeineCacheManager caffeineCacheManager = new CaffeineCacheManager(METRIC_TAG_COLLECTION_CACHE_NAME);
         caffeineCacheManager.setCaffeine(Caffeine.newBuilder()
                 .expireAfterWrite(86400, TimeUnit.SECONDS)

metric-module/metric/src/main/java/com/navercorp/pinpoint/metric/collector/config/MetricCollectorProperties.java

@@ -0,0 +1,50 @@
+/*
+ * Copyright 2025 NAVER Corp.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.navercorp.pinpoint.metric.collector.config;
+
+import com.navercorp.pinpoint.common.server.config.AnnotationVisitor;
+import com.navercorp.pinpoint.common.server.config.LoggingEvent;
+import jakarta.annotation.PostConstruct;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author minwoo-jung
+ */
+@Component
+public class MetricCollectorProperties {
+
+    private final Logger logger = LogManager.getLogger(MetricCollectorProperties.class);
+
+    @Value("${metric.cache.size.tag:10000}")
+    private int metricTagCacheSize;
+
+    public int getMetricTagCacheSize() {
+        return metricTagCacheSize;
+    }
+
+
+    @PostConstruct
+    public void log() {
+        logger.info("{}", this);
+        AnnotationVisitor<Value> annotationVisitor = new AnnotationVisitor<>(Value.class);
+        annotationVisitor.visit(this, new LoggingEvent(this.logger));
+    }
+
+}

metric-module/metric/src/main/resources/pinot-collector/profiles/local/collector-metric.properties

@@ -0,0 +1 @@
+metric.cache.size.tag=10000

metric-module/metric/src/main/resources/pinot-collector/profiles/release/collector-metric.properties

@@ -0,0 +1 @@
+metric.cache.size.tag=10000