r Flytter Kafka producers/consumers til relevant sub-domene

Forsøker å gjøre det samme med Kafka som med DB - at håndtering bor i hvert enkelt subdomene. Så en i enda større grad kan operere innenfor en og samme pakkestruktur når en jobber med en problemstilling. Det er sjeldent det er aktuelt å jobbe med Kafka på tvers. Det er kun config.
navikt · Feb 16, 2023 · 2fe304f · 2fe304f
1 parent 671ffe0
commit 2fe304f
Show file tree

Hide file tree

Showing 17 changed files with 24 additions and 23 deletions.
diff --git a/...ering/kafka/formidlingsgruppe/AfterDto.kt → ...soker/formidlingsgruppe/kafka/AfterDto.kt b/...ering/kafka/formidlingsgruppe/AfterDto.kt → ...soker/formidlingsgruppe/kafka/AfterDto.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 internal class AfterDto(
     val PERSON_ID: String,

diff --git a/...ring/kafka/formidlingsgruppe/BeforeDto.kt → ...oker/formidlingsgruppe/kafka/BeforeDto.kt b/...ring/kafka/formidlingsgruppe/BeforeDto.kt → ...oker/formidlingsgruppe/kafka/BeforeDto.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 internal data class BeforeDto(
     val PERSON_ID: String,

diff --git a/...gsgruppe/DeleteFormidlingsgruppeMapper.kt → ...pe/kafka/DeleteFormidlingsgruppeMapper.kt b/...gsgruppe/DeleteFormidlingsgruppeMapper.kt → ...pe/kafka/DeleteFormidlingsgruppeMapper.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.Formidlingsgruppe
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.FormidlingsgruppeEndretEvent

diff --git a/...sgruppe/FormidlingsgruppeKafkaConsumer.kt → ...e/kafka/FormidlingsgruppeKafkaConsumer.kt b/...sgruppe/FormidlingsgruppeKafkaConsumer.kt → ...e/kafka/FormidlingsgruppeKafkaConsumer.kt
@@ -1,9 +1,9 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 import no.nav.common.featuretoggle.UnleashClient
 import no.nav.common.log.MDCConstants
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.FormidlingsgruppeMottakService
-import no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe.FormidlingsgruppeMapper.Companion.map
+import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka.FormidlingsgruppeMapper.Companion.map
 import no.nav.fo.veilarbregistrering.log.CallId.leggTilCallId
 import no.nav.fo.veilarbregistrering.log.logger
 import org.apache.kafka.clients.consumer.ConsumerRecord

diff --git a/...midlingsgruppe/FormidlingsgruppeMapper.kt → ...gsgruppe/kafka/FormidlingsgruppeMapper.kt b/...midlingsgruppe/FormidlingsgruppeMapper.kt → ...gsgruppe/kafka/FormidlingsgruppeMapper.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 import com.fasterxml.jackson.core.JsonProcessingException
 import com.fasterxml.jackson.databind.DeserializationFeature

diff --git a/...lingsgruppe/GgArenaFormidlinggruppeDto.kt → ...ruppe/kafka/GgArenaFormidlinggruppeDto.kt b/...lingsgruppe/GgArenaFormidlinggruppeDto.kt → ...ruppe/kafka/GgArenaFormidlinggruppeDto.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 /**
   GgArenaFormidlingsgruppe representerer Json som publiseres på `gg-arena-formidlingsgruppe-v1`

diff --git a/...gsgruppe/InsertFormidlingsgruppeMapper.kt → ...pe/kafka/InsertFormidlingsgruppeMapper.kt b/...gsgruppe/InsertFormidlingsgruppeMapper.kt → ...pe/kafka/InsertFormidlingsgruppeMapper.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.Formidlingsgruppe
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.FormidlingsgruppeEndretEvent

diff --git a/...gsgruppe/UpdateFormidlingsgruppeMapper.kt → ...pe/kafka/UpdateFormidlingsgruppeMapper.kt b/...gsgruppe/UpdateFormidlingsgruppeMapper.kt → ...pe/kafka/UpdateFormidlingsgruppeMapper.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.Formidlingsgruppe
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.FormidlingsgruppeEndretEvent

diff --git a/...ring/kafka/meldekort/MeldekortEventDto.kt → ...oker/meldekort/kafka/MeldekortEventDto.kt b/...ring/kafka/meldekort/MeldekortEventDto.kt → ...oker/meldekort/kafka/MeldekortEventDto.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.meldekort
+package no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.kafka
 
 import no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.MeldekortEvent
 import no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.MeldekortPeriode

diff --git a/...kafka/meldekort/MeldekortKafkaConsumer.kt → ...meldekort/kafka/MeldekortKafkaConsumer.kt b/...kafka/meldekort/MeldekortKafkaConsumer.kt → ...meldekort/kafka/MeldekortKafkaConsumer.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.meldekort
+package no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.kafka
 
 import no.nav.common.featuretoggle.UnleashClient
 import no.nav.common.log.MDCConstants

diff --git a/src/main/kotlin/no/nav/fo/veilarbregistrering/kafka/KafkaConfig.kt b/src/main/kotlin/no/nav/fo/veilarbregistrering/kafka/KafkaConfig.kt
@@ -10,10 +10,10 @@ import no.nav.common.featuretoggle.UnleashClient
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.FormidlingsgruppeMottakService
 import no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.MeldekortMottakService
 import no.nav.fo.veilarbregistrering.config.isProduction
-import no.nav.fo.veilarbregistrering.kafka.arbeidsssoker.ArbeidssokerProfilertKafkaProducer
-import no.nav.fo.veilarbregistrering.kafka.arbeidsssoker.ArbeidssokerRegistrertKafkaProducer
-import no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe.FormidlingsgruppeKafkaConsumer
-import no.nav.fo.veilarbregistrering.kafka.meldekort.MeldekortKafkaConsumer
+import no.nav.fo.veilarbregistrering.registrering.publisering.kafka.ArbeidssokerProfilertKafkaProducer
+import no.nav.fo.veilarbregistrering.registrering.publisering.kafka.ArbeidssokerRegistrertKafkaProducer
+import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka.FormidlingsgruppeKafkaConsumer
+import no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.kafka.MeldekortKafkaConsumer
 import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerProfilertProducer
 import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerRegistrertProducer
 import org.apache.kafka.clients.CommonClientConfigs

diff --git a/...ker/ArbeidssokerProfilertKafkaProducer.kt → ...fka/ArbeidssokerProfilertKafkaProducer.kt b/...ker/ArbeidssokerProfilertKafkaProducer.kt → ...fka/ArbeidssokerProfilertKafkaProducer.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.arbeidsssoker
+package no.nav.fo.veilarbregistrering.registrering.publisering.kafka
 
 import no.nav.arbeid.soker.profilering.ArbeidssokerProfilertEvent
 import no.nav.arbeid.soker.profilering.ProfilertTil

diff --git a/...er/ArbeidssokerRegistrertKafkaProducer.kt → ...ka/ArbeidssokerRegistrertKafkaProducer.kt b/...er/ArbeidssokerRegistrertKafkaProducer.kt → ...ka/ArbeidssokerRegistrertKafkaProducer.kt
@@ -1,8 +1,8 @@
-package no.nav.fo.veilarbregistrering.kafka.arbeidsssoker
+package no.nav.fo.veilarbregistrering.registrering.publisering.kafka
 
 import no.nav.arbeid.soker.registrering.ArbeidssokerRegistrertEvent
 import no.nav.common.log.MDCConstants
-import no.nav.fo.veilarbregistrering.kafka.arbeidsssoker.ArbeidssokerRegistrertMapper.map
+import no.nav.fo.veilarbregistrering.registrering.publisering.kafka.ArbeidssokerRegistrertMapper.map
 import no.nav.fo.veilarbregistrering.log.CallId.correlationIdAsBytes
 import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerRegistrertInternalEvent
 import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerRegistrertProducer

diff --git a/...idsssoker/ArbeidssokerRegistrertMapper.kt → ...ing/kafka/ArbeidssokerRegistrertMapper.kt b/...idsssoker/ArbeidssokerRegistrertMapper.kt → ...ing/kafka/ArbeidssokerRegistrertMapper.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.arbeidsssoker
+package no.nav.fo.veilarbregistrering.registrering.publisering.kafka
 
 import no.nav.arbeid.soker.registrering.ArbeidssokerRegistrertEvent
 import no.nav.fo.veilarbregistrering.besvarelse.UtdanningBestattSvar

diff --git a/...ingsgruppe/FormidlingsgruppeMapperTest.kt → ...uppe/kafka/FormidlingsgruppeMapperTest.kt b/...ingsgruppe/FormidlingsgruppeMapperTest.kt → ...uppe/kafka/FormidlingsgruppeMapperTest.kt
@@ -1,8 +1,9 @@
-package no.nav.fo.veilarbregistrering.kafka.formidlingsgruppe
+package no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka
 
 import no.nav.fo.veilarbregistrering.FileToJson.toJson
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.Formidlingsgruppe
 import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.Operation
+import no.nav.fo.veilarbregistrering.arbeidssoker.formidlingsgruppe.kafka.FormidlingsgruppeMapper
 import org.assertj.core.api.Assertions.assertThat
 import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.assertThrows

diff --git a/.../kafka/meldekort/MeldekortEventDtoTest.kt → .../meldekort/kafka/MeldekortEventDtoTest.kt b/.../kafka/meldekort/MeldekortEventDtoTest.kt → .../meldekort/kafka/MeldekortEventDtoTest.kt
@@ -1,4 +1,4 @@
-package no.nav.fo.veilarbregistrering.kafka.meldekort
+package no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.kafka
 
 import no.nav.fo.veilarbregistrering.FileToJson.toJson
 import no.nav.fo.veilarbregistrering.arbeidssoker.meldekort.Meldekorttype

diff --git a/...soker/ArbeidssokerRegistrertMapperTest.kt → ...kafka/ArbeidssokerRegistrertMapperTest.kt b/...soker/ArbeidssokerRegistrertMapperTest.kt → ...kafka/ArbeidssokerRegistrertMapperTest.kt
@@ -1,12 +1,12 @@
-package no.nav.fo.veilarbregistrering.kafka.arbeidssoker
+package no.nav.fo.veilarbregistrering.registrering.publisering.kafka
 
 import no.nav.arbeid.soker.registrering.UtdanningBestattSvar
 import no.nav.arbeid.soker.registrering.UtdanningGodkjentSvar
 import no.nav.arbeid.soker.registrering.UtdanningSvar
 import no.nav.fo.veilarbregistrering.besvarelse.BesvarelseTestdataBuilder.gyldigBesvarelse
 import no.nav.fo.veilarbregistrering.besvarelse.DinSituasjonSvar
 import no.nav.fo.veilarbregistrering.bruker.AktorId
-import no.nav.fo.veilarbregistrering.kafka.arbeidsssoker.ArbeidssokerRegistrertMapper
+import no.nav.fo.veilarbregistrering.registrering.publisering.kafka.ArbeidssokerRegistrertMapper
 import no.nav.fo.veilarbregistrering.registrering.publisering.ArbeidssokerRegistrertInternalEvent
 import org.assertj.core.api.Assertions.assertThat
 import org.junit.jupiter.api.Test