f Hvis dev, publiser meldinger til aiven-topics parallelt

navikt · Aug 31, 2021 · 8d6b3d1 · 8d6b3d1
1 parent cdb9c55
commit 8d6b3d1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/main/java/no/nav/fo/veilarbregistrering/kafka/KafkaConfig.java b/src/main/java/no/nav/fo/veilarbregistrering/kafka/KafkaConfig.java
@@ -54,7 +54,7 @@ ArbeidssokerRegistrertKafkaProducer arbeidssokerRegistrertKafkaProducerAiven(@Qu
     ArbeidssokerProfilertKafkaProducer arbeidssokerProfilertKafkaProducerAiven(@Qualifier("producerAiven") KafkaProducer kafkaProducerAiven) {
         return new ArbeidssokerProfilertKafkaProducer(
                 kafkaProducerAiven,
-                "paw.paw-test-topic");
+                "paw.arbeidssoker-profilert-v1");
     }
 
     @Bean("producerOnprem")

diff --git a/...java/no/nav/fo/veilarbregistrering/registrering/publisering/PubliseringAvEventsService.kt b/...java/no/nav/fo/veilarbregistrering/registrering/publisering/PubliseringAvEventsService.kt
@@ -50,7 +50,9 @@ class PubliseringAvEventsService(
             ordinaerBrukerRegistrering.opprettetDato
         ).also {
             arbeidssokerRegistrertProducer.publiserArbeidssokerRegistrert(it)
-            //arbeidssokerRegistrertProducerAiven.publiserArbeidssokerRegistrert(it)
+            if (System.getenv("APP_ENVIRONMENT_NAME") == "dev") {
+                arbeidssokerRegistrertProducerAiven.publiserArbeidssokerRegistrert(it)
+            }
         }
 
         arbeidssokerProfilertProducer.publiserProfilering(