Enabling disabled_metrics config for Micrometer (#1421)

Author: eyalkoren

CHANGELOG.asciidoc

@@ -38,6 +38,7 @@ endif::[]
 metricset tag keys - {pull}1413[1413]
 * Fix invalid micrometer metrics with non-numeric values {pull}1419[1419]
 * Fix `NoClassDefFoundError` with JDBC instrumentation plugin {pull}1409[1409]
+* Apply `disable_metrics` config to Micrometer metrics - {pull}1421[1421]
 
 [[release-notes-1.x]]
 === Java Agent version 1.x

apm-agent-plugins/apm-micrometer-plugin/src/main/java/co/elastic/apm/agent/micrometer/MicrometerMetricsReporter.java

@@ -26,6 +26,7 @@
 
 import co.elastic.apm.agent.impl.ElasticApmTracer;
 import co.elastic.apm.agent.impl.Tracer;
+import co.elastic.apm.agent.matcher.WildcardMatcher;
 import co.elastic.apm.agent.report.Reporter;
 import co.elastic.apm.agent.report.ReporterConfiguration;
 import co.elastic.apm.agent.sdk.weakmap.WeakMapSupplier;
@@ -37,6 +38,7 @@
 import org.slf4j.LoggerFactory;
 
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Consumer;
@@ -88,7 +90,7 @@ public void run() {
             return;
         }
         final long timestamp = System.currentTimeMillis() * 1000;
-        MeterMapConsumer meterConsumer = new MeterMapConsumer();
+        MeterMapConsumer meterConsumer = new MeterMapConsumer(tracer.getConfig(ReporterConfiguration.class).getDisableMetrics());
         for (MeterRegistry registry : meterRegistries) {
             registry.forEachMeter(meterConsumer);
         }
@@ -97,11 +99,21 @@ public void run() {
     }
 
     private static class MeterMapConsumer implements Consumer<Meter> {
+
+        private final List<WildcardMatcher> disabledMetrics;
+
+        public MeterMapConsumer(List<WildcardMatcher> disabledMetrics) {
+            this.disabledMetrics = disabledMetrics;
+        }
+
         final Map<Meter.Id, Meter> meters = new HashMap<>();
 
         @Override
         public void accept(Meter meter) {
-            meters.put(meter.getId(), meter);
+            Meter.Id meterId = meter.getId();
+            if (WildcardMatcher.isNoneMatch(disabledMetrics, meterId.getName())) {
+                meters.put(meterId, meter);
+            }
         }
     }
 

apm-agent-plugins/apm-micrometer-plugin/src/test/java/co/elastic/apm/agent/micrometer/MicrometerMetricsReporterTest.java

@@ -27,6 +27,7 @@
 import co.elastic.apm.agent.MockReporter;
 import co.elastic.apm.agent.MockTracer;
 import co.elastic.apm.agent.impl.ElasticApmTracer;
+import co.elastic.apm.agent.matcher.WildcardMatcher;
 import co.elastic.apm.agent.report.ReporterConfiguration;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
@@ -64,14 +65,15 @@ class MicrometerMetricsReporterTest {
     private MicrometerMetricsReporter metricsReporter;
     private MockReporter reporter;
     private ObjectMapper objectMapper = new ObjectMapper();
+    private ElasticApmTracer tracer;
 
     @BeforeEach
     void setUp() {
         SimpleMeterRegistry simpleMeterRegistry = new SimpleMeterRegistry();
         CompositeMeterRegistry nestedCompositeMeterRegistry = new CompositeMeterRegistry(Clock.SYSTEM, List.of(simpleMeterRegistry));
         meterRegistry = new CompositeMeterRegistry(Clock.SYSTEM, List.of(nestedCompositeMeterRegistry));
         reporter = new MockReporter();
-        ElasticApmTracer tracer = MockTracer.createRealTracer(reporter);
+        tracer = MockTracer.createRealTracer(reporter);
         doReturn(0L).when(tracer.getConfig(ReporterConfiguration.class)).getMetricsIntervalMs();
         metricsReporter = new MicrometerMetricsReporter(tracer);
         metricsReporter.registerMeterRegistry(meterRegistry);
@@ -93,6 +95,22 @@ void testSameMetricSet() {
         assertThat(metricSet.get("metricset").get("samples").get("gauge").get("value").doubleValue()).isEqualTo(42);
     }
 
+    @Test
+    void testDisabledMetrics() {
+        doReturn(List.of(WildcardMatcher.valueOf("root.metric"), WildcardMatcher.valueOf("root.metric.exclude.*")))
+            .when(tracer.getConfig(ReporterConfiguration.class)).getDisableMetrics();
+
+        List<Tag> tags = List.of(Tag.of("foo", "bar"));
+        meterRegistry.counter("root.metric", tags).increment(42);
+        meterRegistry.counter("root.metric.include", tags).increment(42);
+        meterRegistry.counter("root.metric.exclude.counter", tags).increment(42);
+
+        JsonNode metricSet = getSingleMetricSet();
+        assertThat(metricSet.get("metricset").get("tags").get("foo").textValue()).isEqualTo("bar");
+        assertThat(metricSet.get("metricset").get("samples")).hasSize(1);
+        assertThat(metricSet.get("metricset").get("samples").get("root.metric.include").get("value").doubleValue()).isEqualTo(42);
+    }
+
     @Test
     void testTagsSanitation() {
         List<Tag> tags = List.of(