Lagt til manglende kafka i deploy descriptor

navikt · Nov 21, 2024 · 7011d1b · 7011d1b
1 parent 292507f
commit 7011d1b
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/apps/kafka-key-generator/nais/nais-dev.yaml b/apps/kafka-key-generator/nais/nais-dev.yaml
@@ -43,6 +43,8 @@ spec:
     autoInstrumentation:
       enabled: true
       runtime: java
+  kafka:
+      pool: nav-dev
   gcp:
     sqlInstances:
       - type: POSTGRES_14

diff --git a/apps/kafka-key-generator/nais/nais-prod.yaml b/apps/kafka-key-generator/nais/nais-prod.yaml
@@ -41,6 +41,8 @@ spec:
     autoInstrumentation:
       enabled: true
       runtime: java
+  kafka:
+      pool: nav-prod
   gcp:
     sqlInstances:
       - type: POSTGRES_14

diff --git a/...ka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/service/KafkaKeysService.kt b/...ka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/service/KafkaKeysService.kt
@@ -12,7 +12,7 @@ import no.nav.paw.kafkakeygenerator.mergedetector.vo.MergeDetected
 import no.nav.paw.kafkakeygenerator.repository.KafkaKeysRepository
 import no.nav.paw.kafkakeygenerator.utils.buildLogger
 import no.nav.paw.kafkakeygenerator.utils.countRestApiFailed
-import no.nav.paw.kafkakeygenerator.utils.countRestApiFetch
+import no.nav.paw.kafkakeygenerator.utils.countRestApiFetched
 import no.nav.paw.kafkakeygenerator.utils.countRestApiInserted
 import no.nav.paw.kafkakeygenerator.utils.countRestApiReceived
 import no.nav.paw.kafkakeygenerator.vo.ArbeidssoekerId
@@ -132,7 +132,7 @@ class KafkaKeysService(
     @WithSpan
     suspend fun hent(callId: CallId, identitet: Identitetsnummer): Either<Failure, ArbeidssoekerId> {
         logger.debug("Henter identer fra database")
-        meterRegistry.countRestApiFetch()
+        meterRegistry.countRestApiFetched()
         return kafkaKeysRepository.hent(identitet)
             .suspendingRecover(DB_NOT_FOUND) {
                 sjekkMotAliaser(callId, identitet)

diff --git a/apps/kafka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/utils/Metrics.kt b/apps/kafka-key-generator/src/main/kotlin/no/nav/paw/kafkakeygenerator/utils/Metrics.kt
@@ -25,8 +25,8 @@ fun MeterRegistry.countRestApiReceived() {
     genericCounter("rest_api", "database", "received")
 }
 
-fun MeterRegistry.countRestApiFetch() {
-    genericCounter("rest_api", "database", "fetch")
+fun MeterRegistry.countRestApiFetched() {
+    genericCounter("rest_api", "database", "fetched")
 }
 
 fun MeterRegistry.countRestApiInserted() {