IS-2477: Remove unused kafka embedded (#529)

Author: andersrognstad

build.gradle.kts

@@ -16,7 +16,6 @@ val jsonVersion = "20240303"
 val jettyVersion = "9.4.54.v20240208"
 val joseVersion = "0.9.4"
 val kafkaVersion = "3.7.0"
-val kafkaEmbeddedVersion = "3.2.5"
 val ktorVersion = "2.3.11"
 val kluentVersion = "1.73"
 val jaxbApiVersion = "2.3.1"
@@ -191,7 +190,6 @@ dependencies {
             }
         }
     }
-    testImplementation("no.nav:kafka-embedded-env:$kafkaEmbeddedVersion", excludeLog4j)
 
     implementation("no.nav.tjenestespesifikasjoner:servicemeldingMedKontaktinformasjon-v1-tjenestespesifikasjon:$tjenesteSpesifikasjonerGithubVersion")
 

src/test/kotlin/no/nav/syfo/testhelper/ExternalMockEnvironment.kt

@@ -1,15 +1,13 @@
 package no.nav.syfo.testhelper
 
 import io.ktor.server.netty.*
-import no.nav.common.KafkaEnvironment
 import no.nav.syfo.application.ApplicationState
 import no.nav.syfo.testhelper.mock.*
 import java.util.*
 
 class ExternalMockEnvironment private constructor() {
     val applicationState: ApplicationState = testAppState()
     val database = TestDatabase()
-    val embeddedEnvironment: KafkaEnvironment = testKafka()
     val azureAdV2Mock = AzureAdV2Mock()
     val tokendingsMock = TokendingsMock()
     val dokarkivMock = DokarkivMock()
@@ -37,7 +35,6 @@ class ExternalMockEnvironment private constructor() {
     )
 
     var environment = testEnvironment(
-        kafkaBootstrapServers = embeddedEnvironment.brokersURL,
         azureTokenEndpoint = azureAdV2Mock.url,
         tokenxEndpoint = tokendingsMock.url,
         dokarkivUrl = dokarkivMock.url,
@@ -70,14 +67,12 @@ class ExternalMockEnvironment private constructor() {
 
 fun ExternalMockEnvironment.startExternalMocks() {
     this.externalApplicationMockMap.start()
-    this.embeddedEnvironment.start()
     this.redisServer.start()
 }
 
 fun ExternalMockEnvironment.stopExternalMocks() {
     this.externalApplicationMockMap.stop()
     this.database.stop()
-    this.embeddedEnvironment.tearDown()
     this.redisServer.stop()
 }
 

src/test/kotlin/no/nav/syfo/testhelper/TestEnvironment.kt

@@ -8,7 +8,6 @@ import java.net.ServerSocket
 import java.time.LocalDate
 
 fun testEnvironment(
-    kafkaBootstrapServers: String,
     dokarkivUrl: String = "http://dokarkiv",
     azureTokenEndpoint: String = "azureTokenEndpoint",
     tokenxEndpoint: String = "tokenxEndpoint",
@@ -36,7 +35,7 @@ fun testEnvironment(
     eregUrl = eregUrl,
     electorPath = "electorPath",
     kafka = ApplicationEnvironmentKafka(
-        aivenBootstrapServers = kafkaBootstrapServers,
+        aivenBootstrapServers = "kafkaBootstrapServers",
         aivenSchemaRegistryUrl = "http://kafka-schema-registry.tpa.svc.nais.local:8081",
         aivenRegistryUser = "registryuser",
         aivenRegistryPassword = "registrypassword",