f Bean for profilertmeldinger og sender til test-topic i dev

src/main/java/no/nav/fo/veilarbregistrering/config/ServiceBeansConfig.java

@@ -276,7 +276,10 @@ PubliseringAvEventsService publiseringAvEventsService(
             @Qualifier("arbeidssokerRegistrertKafkaProducerAiven")
             ArbeidssokerRegistrertProducer arbeidssokerRegistrertProducerAiven,
             RegistreringTilstandRepository registreringTilstandRepository,
+            @Qualifier("arbeidssokerProfilertKafkaProducer")
             ArbeidssokerProfilertProducer arbeidssokerProfilertProducer,
+            @Qualifier("arbeidssokerProfilertKafkaProducerAiven")
+            ArbeidssokerProfilertProducer arbeidssokerProfilertProducerAiven,
             PrometheusMetricsService prometheusMetricsService) {
         return new PubliseringAvEventsService(
                 profileringRepository,
@@ -285,6 +288,7 @@ PubliseringAvEventsService publiseringAvEventsService(
                 arbeidssokerRegistrertProducerAiven,
                 registreringTilstandRepository,
                 arbeidssokerProfilertProducer,
+                arbeidssokerProfilertProducerAiven,
                 prometheusMetricsService);
     }
 

src/main/java/no/nav/fo/veilarbregistrering/kafka/KafkaConfig.java

@@ -46,6 +46,13 @@ ArbeidssokerProfilertKafkaProducer arbeidssokerProfilertKafkaProducer(@Qualifier
     @Bean
     ArbeidssokerRegistrertKafkaProducer arbeidssokerRegistrertKafkaProducerAiven(@Qualifier("producerAiven") KafkaProducer kafkaProducerAiven) {
         return new ArbeidssokerRegistrertKafkaProducer(
+                kafkaProducerAiven,
+                "paw.arbeidssoker-registrert-v1");
+    }
+
+    @Bean
+    ArbeidssokerProfilertKafkaProducer arbeidssokerProfilertKafkaProducerAiven(@Qualifier("producerAiven") KafkaProducer kafkaProducerAiven) {
+        return new ArbeidssokerProfilertKafkaProducer(
                 kafkaProducerAiven,
                 "paw.paw-test-topic");
     }

src/main/java/no/nav/fo/veilarbregistrering/registrering/publisering/PubliseringAvEventsService.kt

@@ -18,6 +18,7 @@ class PubliseringAvEventsService(
     private val arbeidssokerRegistrertProducerAiven: ArbeidssokerRegistrertProducer,
     private val registreringTilstandRepository: RegistreringTilstandRepository,
     private val arbeidssokerProfilertProducer: ArbeidssokerProfilertProducer,
+    private val arbeidssokerProfilertProducerAiven: ArbeidssokerProfilertProducer,
     private val prometheusMetricsService: PrometheusMetricsService
 ) {
     @Transactional
@@ -49,21 +50,22 @@ class PubliseringAvEventsService(
             ordinaerBrukerRegistrering.opprettetDato
         ).also {
             arbeidssokerRegistrertProducer.publiserArbeidssokerRegistrert(it)
-            if (System.getenv("APP_ENVIRONMENT_NAME") == "dev") {
-                try {
-                    LOG.info("Producing message on aiven topic")
-                    arbeidssokerRegistrertProducerAiven.publiserArbeidssokerRegistrert(it)
-                } catch (e: Exception) {
-                    LOG.warn("Producing message on aiven topic FAILED with error {}", e)
-                }
-            }
+            //arbeidssokerRegistrertProducerAiven.publiserArbeidssokerRegistrert(it)
         }
 
         arbeidssokerProfilertProducer.publiserProfilering(
             bruker.aktorId,
             profilering.innsatsgruppe,
             ordinaerBrukerRegistrering.opprettetDato
         )
+
+        if (System.getenv("APP_ENVIRONMENT_NAME") == "dev") {
+            arbeidssokerProfilertProducerAiven.publiserProfilering(
+                bruker.aktorId,
+                profilering.innsatsgruppe,
+                ordinaerBrukerRegistrering.opprettetDato
+            )
+        }
     }
 
     private fun rapporterRegistreringStatusAntallForPublisering() {

src/test/java/no/nav/fo/veilarbregistrering/kafka/KafkaConfig.kt

@@ -15,5 +15,8 @@ class KafkaConfig {
     fun arbeidssokerRegistrertKafkaProducerAiven(): ArbeidssokerRegistrertProducer = mockk()
 
     @Bean
-    fun arbeidssokerProfilertProducer(): ArbeidssokerProfilertProducer = mockk()
+    fun arbeidssokerProfilertKafkaProducer(): ArbeidssokerProfilertProducer = mockk()
+
+    @Bean
+    fun arbeidssokerProfilertKafkaProducerAiven(): ArbeidssokerProfilertProducer = mockk()
 }