StatisticsServiceTest, PrometheusMetricsRetrieverTest fix

Author: iliax

api/src/main/java/io/kafbat/ui/service/metrics/scrape/prometheus/PrometheusMetricsRetriever.java

@@ -48,6 +48,9 @@ Mono<List<MetricSnapshot>> retrieve(String host) {
         .bodyToMono(String.class)
         .doOnError(e -> log.error("Error while getting metrics from {}", host, e))
         .map(body -> new PrometheusTextFormatParser().parse(body))
-        .onErrorResume(th -> Mono.just(List.of()));
+        .onErrorResume(th -> {
+          log.warn("Error while getting prometheus metrics from {}", host, th);
+          return Mono.just(List.of());
+        });
   }
 }

api/src/main/java/io/kafbat/ui/service/metrics/scrape/prometheus/PrometheusTextFormatParser.java

@@ -101,7 +101,7 @@ private void parseMetricLine(String line, ParsingContext cxt) {
       String timestampString = m.group(4);
       cxt.dataPoint(
           new ParsedDataPoint(
-              PrometheusNaming.sanitizeMetricName(metricName),
+              metricName,
               Optional.ofNullable(labelsString).map(this::parseLabels).orElse(Labels.EMPTY),
               parseDouble(valueString),
               Optional.ofNullable(timestampString).map(Long::parseLong).orElse(0L)));
@@ -180,7 +180,7 @@ void metricNameAndHelp(String metricName, String help) {
 
     void dataPoint(ParsedDataPoint parsedDataPoint) {
       if (currentMetricName == null) {
-        currentMetricName = parsedDataPoint.name;
+        currentMetricName = PrometheusNaming.sanitizeMetricName(parsedDataPoint.name);
       }
       if (dataPoints == null) {
         dataPoints = new UntypedDataPointsAccumulator();