This is an automated email from the ASF dual-hosted git repository.

pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 1f02f2a7f4dc chore(micrometer): make it easier to scrape
1f02f2a7f4dc is described below

commit 1f02f2a7f4dc0139ee70d4071f071430ded1bf2f
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Tue Mar 3 08:59:57 2026 +0100

    chore(micrometer): make it easier to scrape
---
 .../component/micrometer/json/AbstractMicrometerService.java      | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/json/AbstractMicrometerService.java
 
b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/json/AbstractMicrometerService.java
index 82d382bc6a9c..b35e28ada0da 100644
--- 
a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/json/AbstractMicrometerService.java
+++ 
b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/json/AbstractMicrometerService.java
@@ -187,7 +187,7 @@ public class AbstractMicrometerService extends 
ServiceSupport {
     @Override
     protected void doStop() {
         if (logMetricsOnShutdown) {
-            LOG.info("Micrometer component is stopping, here a list of metrics 
collected so far.");
+            LOG.warn("Micrometer service is stopping, here a list of metrics 
collected so far.");
             // Default: all metrics
             logMetricsOnShutdown(logMetricsOnShutdownFilters == null ? new 
String[] { "*" } : logMetricsOnShutdownFilters);
         }
@@ -249,7 +249,11 @@ public class AbstractMicrometerService extends 
ServiceSupport {
                 .map(AbstractMicrometerService::convertMeterToMap)
                 .forEach(logEntry -> {
                     try {
-                        LOG.info(mapper.writeValueAsString(logEntry));
+                        // We put on warn level to make sure it is printed 
even if the log is
+                        // at higher levels. Important: we also include a 
start and end tag to make sure the
+                        // scraper can more easily identify the metric content.
+                        String metric = "#METRIC-START#" + 
mapper.writeValueAsString(logEntry) + "#METRIC-END#";
+                        LOG.warn(metric);
                     } catch (Exception e) {
                         LOG.error("Error logging metric " + 
logEntry.get("name"), e);
                     }

Reply via email to