Merge pull request #315 from uptane/kafka-metrics-fix

Do not cast kafka metrics to Object
uptane · Nov 10, 2023 · 3e02e27 · 3e02e27
2 parents 35c0f4b + 4c59090
commit 3e02e27
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...essaging/src/main/scala/com/advancedtelematic/libats/messaging/metrics/KafkaMetrics.scala b/...essaging/src/main/scala/com/advancedtelematic/libats/messaging/metrics/KafkaMetrics.scala
@@ -42,8 +42,8 @@ class KafkaMetrics extends MetricsReporter {
   override def metricChange(metric: KafkaMetric): Unit = try {
     metricRegistry.register(
       metricName(metric),
-      new Gauge[Double] {
-        override def getValue: Double = metric.metricValue().asInstanceOf[Double]
+      new Gauge[Object] {
+        override def getValue: Object = metric.metricValue()
       })
   } catch {
     case ex: IllegalArgumentException if ex.getMessage.contains("already exists") =>