kan vi gjøre dette istedenfor?

navikt · Aug 27, 2024 · c167374 · c167374
1 parent a1d22f4
commit c167374
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/rapids-and-rivers/src/main/kotlin/com/github/navikt/tbd_libs/rapids_and_rivers/KafkaRapid.kt b/rapids-and-rivers/src/main/kotlin/com/github/navikt/tbd_libs/rapids_and_rivers/KafkaRapid.kt
@@ -43,6 +43,9 @@ class KafkaRapid(
 
     init {
         log.info("rapid initialized, autoCommit=$autoCommit")
+
+        KafkaClientMetrics(consumer).bindTo(meterRegistry)
+        KafkaClientMetrics(producer).bindTo(meterRegistry)
     }
 
     fun seekToBeginning() {
@@ -215,8 +218,6 @@ class KafkaRapid(
         }
     }
 
-    fun getMetrics() = listOf(KafkaClientMetrics(consumer), KafkaClientMetrics(producer))
-
     companion object {
         private const val Stopped = false
         private const val Started = true