Ny tilbakekreving ns (#1046)

### 💰 Hva skal gjøres, og hvorfor? _Skriv 1 eller 2 setninger om hvilken funksjonell endring som blir implementert. Ta med en **lenke til Favro** og skriv en kort beskrivelse av hvorfor endringen skal gjøres._ ### 🔎️ Er det noe spesielt du ønsker tilbakemelding om? _Er det noe du er usikker på eller ønsker å diskutere? Beskriv det gjerne her eller kommenter koden det gjelder._ ### ✅ Checklist _Har du husket alle punktene i listen?_ - [ ] Jeg har testet mine endringer i henhold til akseptansekriteriene 🕵️ - [x] Jeg har config- eller sql-endringer. I så fall, husk manuell deploy til miljø for å verifisere endringene. - [ ] Jeg har skrevet tester. Hvis du ikke har skrevet tester, beskriv hvorfor under 👇 _Jeg har ikke skrevet tester fordi:_ ### 💬 Ønsker du en muntlig gjennomgang? - [x] Ja - [ ] Nei
navikt · Jan 27, 2025 · 8b3d040 · 8b3d040
1 parent 296ff38
commit 8b3d040
Show file tree

Hide file tree

Showing 7 changed files with 17 additions and 13 deletions.
diff --git a/.deploy/nais/app-preprod.yaml b/.deploy/nais/app-preprod.yaml
@@ -86,7 +86,8 @@ spec:
           cluster: dev-fss
         - application: familie-ef-sak
           cluster: dev-gcp
-        - application: familie-tilbake
+        - application: tilbakekreving-backend
+          namespace: tilbake
           cluster: dev-gcp
         - application: familie-oppdrag
           cluster: dev-fss

diff --git a/src/main/kotlin/no/nav/familie/ks/sak/config/KafkaConfig.kt b/src/main/kotlin/no/nav/familie/ks/sak/config/KafkaConfig.kt
@@ -186,8 +186,6 @@ class KafkaConfig(
         const val SAK_TOPIC = "teamfamilie.aapen-kontantstotte-saksstatistikk-sak-v1"
         const val VEDTAK_TOPIC = "teamfamilie.aapen-kontantstotte-vedtak-v1"
         const val KONTANTSTØTTE_FEED_TOPIC = "teamfamilie.aapen-feed-kontantstotte-v1"
-        const val FAGSYSTEMSBEHANDLING_REQUEST_TBK_TOPIC = "teamfamilie.privat-tbk-hentfagsystemsbehandling-request-topic"
-        const val FAGSYSTEMSBEHANDLING_RESPONS_TBK_TOPIC = "teamfamilie.privat-tbk-hentfagsystemsbehandling-respons-topic"
         const val PDL_AKTOR_V2_TOPIC = "pdl.aktor-v2"
     }
 }
diff --git a/...in/no/nav/familie/ks/sak/kjerne/tilbakekreving/HentFagsystemsbehandlingRequestConsumer.kt b/...in/no/nav/familie/ks/sak/kjerne/tilbakekreving/HentFagsystemsbehandlingRequestConsumer.kt
@@ -4,7 +4,6 @@ import no.nav.familie.kontrakter.felles.objectMapper
 import no.nav.familie.kontrakter.felles.tilbakekreving.HentFagsystemsbehandlingRequest
 import no.nav.familie.kontrakter.felles.tilbakekreving.HentFagsystemsbehandlingRespons
 import no.nav.familie.kontrakter.felles.tilbakekreving.Ytelsestype
-import no.nav.familie.ks.sak.config.KafkaConfig
 import no.nav.familie.log.mdc.kjørMedCallId
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.slf4j.LoggerFactory
@@ -23,7 +22,7 @@ class HentFagsystemsbehandlingRequestConsumer(
 
     @KafkaListener(
         id = "familie-ks-sak",
-        topics = [KafkaConfig.FAGSYSTEMSBEHANDLING_REQUEST_TBK_TOPIC],
+        topics = ["\${TILBAKEKREVING_REQUEST_TOPIC}"],
         containerFactory = "concurrentKafkaListenerContainerFactory",
     )
     fun listen(

diff --git a/.../nav/familie/ks/sak/kjerne/tilbakekreving/HentFagsystemsbehandlingResponsKafkaProducer.kt b/.../nav/familie/ks/sak/kjerne/tilbakekreving/HentFagsystemsbehandlingResponsKafkaProducer.kt
@@ -3,8 +3,8 @@ package no.nav.familie.ks.sak.kjerne.tilbakekreving
 import no.nav.familie.kontrakter.felles.objectMapper
 import no.nav.familie.kontrakter.felles.tilbakekreving.HentFagsystemsbehandlingRespons
 import no.nav.familie.ks.sak.common.exception.Feil
-import no.nav.familie.ks.sak.config.KafkaConfig.Companion.FAGSYSTEMSBEHANDLING_RESPONS_TBK_TOPIC
 import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Profile
 import org.springframework.kafka.core.KafkaTemplate
 import org.springframework.stereotype.Service
@@ -22,6 +22,8 @@ interface KafkaProducer {
 @Profile("!integrasjonstest & !dev-postgres-preprod & !postgres")
 class HentFagsystemsbehandlingResponsKafkaProducer(
     private val kafkaTemplate: KafkaTemplate<String, String>,
+    @Value("\${TILBAKEKREVING_RESPONSE_TOPIC}")
+    val tilbakekrevingResponseTopic: String,
 ) : KafkaProducer {
     override fun sendFagsystemsbehandlingRespons(
         melding: HentFagsystemsbehandlingRespons,
@@ -30,16 +32,16 @@ class HentFagsystemsbehandlingResponsKafkaProducer(
     ) {
         val meldingIString: String = objectMapper.writeValueAsString(melding)
         kafkaTemplate
-            .send(FAGSYSTEMSBEHANDLING_RESPONS_TBK_TOPIC, key, meldingIString)
+            .send(tilbakekrevingResponseTopic, key, meldingIString)
             .thenAccept {
                 logger.info(
-                    """Melding på topic $FAGSYSTEMSBEHANDLING_RESPONS_TBK_TOPIC for $behandlingId med $key er sendt. 
+                    """Melding på topic $tilbakekrevingResponseTopic for $behandlingId med $key er sendt. 
                             Fikk offset ${it?.recordMetadata?.offset()}
                     """.trimMargin(),
                 )
             }.exceptionally {
                 val feilmelding =
-                    """Melding på topic $FAGSYSTEMSBEHANDLING_RESPONS_TBK_TOPIC kan ikke sendes for $behandlingId 
+                    """Melding på topic $tilbakekrevingResponseTopic kan ikke sendes for $behandlingId 
                             med $key. Feiler med ${it.message}
                     """.trimMargin()
                 logger.warn(feilmelding)

diff --git a/src/main/resources/application-preprod.yaml b/src/main/resources/application-preprod.yaml
@@ -111,7 +111,9 @@ SANITY_DATASET: "ks-brev"
 PDL_URL: https://pdl-api.dev-fss-pub.nais.io
 PDL_SCOPE: api://dev-fss.pdl.pdl-api/.default
 
-FAMILIE_TILBAKE_API_URL_SCOPE: api://dev-gcp.teamfamilie.familie-tilbake/.default
+FAMILIE_TILBAKE_API_URL_SCOPE: api://dev-gcp.tilbake.tilbakekreving-backend/.default
+TILBAKEKREVING_REQUEST_TOPIC: tilbake.privat-tbk-hentfagsystemsbehandling
+TILBAKEKREVING_RESPONSE_TOPIC: tilbake.privat-tbk-hentfagsystemsbehandling-svar
 
 FAMILIE_EF_SAK_API_URL_SCOPE: api://dev-gcp.teamfamilie.familie-ef-sak/.default
 

diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml
@@ -133,7 +133,9 @@ FAMILIE_PROSESSERING_CLIENT_ID: "dummy"
 FAMILIE_BREV_API_URL: http://familie-brev
 FAMILIE_KLAGE_URL: http://familie-klage
 FAMILIE_KS_INFOTRYGD_API_URL: http://familie-ks-infotrygd
-FAMILIE_TILBAKE_API_URL: http://familie-tilbake/api
+FAMILIE_TILBAKE_API_URL: http://tilbakekreving-backend.tilbake/api
+TILBAKEKREVING_REQUEST_TOPIC: teamfamilie.privat-tbk-hentfagsystemsbehandling-request-topic
+TILBAKEKREVING_RESPONSE_TOPIC: teamfamilie.privat-tbk-hentfagsystemsbehandling-respons-topic
 PDL_URL: http://pdl-api.default
 FAMILIE_INTEGRASJONER_API_URL: http://familie-integrasjoner/api
 FAMILIE_OPPDRAG_API_URL: http://familie-oppdrag/api

diff --git a/src/test/resources/application-dev-postgres-preprod.yaml b/src/test/resources/application-dev-postgres-preprod.yaml
@@ -147,8 +147,8 @@ PDL_SCOPE: api://dev-fss.pdl.pdl-api/.default
 FAMILIE_OPPDRAG_API_URL: https://familie-oppdrag.dev.intern.nav.no/api
 FAMILIE_OPPDRAG_SCOPE: api://dev-fss.teamfamilie.familie-oppdrag/.default
 FAMILIE_BREV_API_URL: https://familie-brev.intern.dev.nav.no
-FAMILIE_TILBAKE_API_URL: https://familie-tilbake.intern.dev.nav.no/api
-FAMILIE_TILBAKE_API_URL_SCOPE: api://dev-gcp.teamfamilie.familie-tilbake/.default
+FAMILIE_TILBAKE_API_URL: https://tilbakekreving-backend.intern.dev.nav.no
+FAMILIE_TILBAKE_API_URL_SCOPE: api://dev-gcp.tilbake.tilbakekreving-backend/.default
 
 FAMILIE_KLAGE_URL: https://familie-klage-backend.intern.dev.nav.no