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);
}