Merge pull request #123 from navikt/chore/move-test-inside-emottak-utils-repo

Move test inside emottak utils repo

Author: kfh

emottak-utils/build.gradle.kts

@@ -34,6 +34,9 @@ publishing {
 
 dependencies {
     testImplementation(kotlin("test"))
+    testImplementation("org.testcontainers:kafka:1.19.0")
+    testImplementation("org.junit.jupiter:junit-jupiter-api:5.4.0")
+    testImplementation("org.junit.jupiter:junit-jupiter-engine:5.4.0")
     implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:1.8.0")
     implementation("io.github.nomisrev:kotlin-kafka:0.4.1")
     implementation("com.sksamuel.hoplite:hoplite-core:2.8.2")

ebms-async/src/test/kotlin/no/nav/emottak/ebms/async/kafka/KafkaPublisherClientTest.kt emottak-utils/src/test/kotlin/no/nav/emottak/utils/kafka/KafkaPublisherClientTest.kt

@@ -1,4 +1,4 @@
-package no.nav.emottak.ebms.async.kafka
+package no.nav.emottak.utils.kafka
 
 import com.sksamuel.hoplite.Masked
 import kotlinx.coroutines.runBlocking
@@ -11,7 +11,6 @@ import no.nav.emottak.utils.config.TruststoreLocation
 import no.nav.emottak.utils.config.TruststoreType
 import no.nav.emottak.utils.events.model.Event
 import no.nav.emottak.utils.events.model.EventType
-import no.nav.emottak.utils.kafka.KafkaPublisherClient
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.apache.kafka.clients.consumer.KafkaConsumer

emottak-utils/src/test/kotlin/no/nav/emottak/utils/kafka/KafkaTestContainer.kt

@@ -0,0 +1,33 @@
+package no.nav.emottak.utils.kafka
+
+import org.apache.kafka.clients.admin.AdminClient
+import org.apache.kafka.clients.admin.AdminClientConfig
+import org.apache.kafka.clients.admin.NewTopic
+import org.testcontainers.containers.KafkaContainer
+import org.testcontainers.utility.DockerImageName
+
+object KafkaTestContainer {
+    private val kafkaContainer: KafkaContainer = KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.5.0"))
+
+    val bootstrapServers: String
+        get() = kafkaContainer.bootstrapServers
+
+    fun start() {
+        kafkaContainer.start()
+    }
+
+    fun stop() {
+        kafkaContainer.stop()
+    }
+
+    fun createTopic(topicName: String, partitions: Int = 1, replicationFactor: Short = 1) {
+        val config = mapOf(
+            AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG to bootstrapServers
+        )
+
+        AdminClient.create(config).use { adminClient ->
+            val newTopic = NewTopic(topicName, partitions, replicationFactor)
+            adminClient.createTopics(listOf(newTopic)).all().get()
+        }
+    }
+}