fix wrong conf var name

navikt · Dec 9, 2021 · f6bf84e · f6bf84e
1 parent a58adb4
commit f6bf84e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 8 deletions.
diff --git a/backend/src/main/kotlin/no/nav/amt_informasjon_api/Application.kt b/backend/src/main/kotlin/no/nav/amt_informasjon_api/Application.kt
@@ -52,7 +52,7 @@ fun Application.module() {
     // TODO: Lag noe som er litt mer robust. Kun for å få deployet.
     if (enableKafka) {
         kafka = KafkaFactory()
-        val kafkaBrokers = appConfig.property("ktor.kafka.kafkaBrokers").getString()
+        val kafkaBrokers = appConfig.property("ktor.kafka.brokers").getString()
         println("KAFKA_BROKERS: $kafkaBrokers")
         environment.monitor.subscribe(ApplicationStopped) {
             println("Shutting down")

diff --git a/backend/src/main/kotlin/no/nav/amt_informasjon_api/kafka/KafkaFactory.kt b/backend/src/main/kotlin/no/nav/amt_informasjon_api/kafka/KafkaFactory.kt
@@ -1,14 +1,10 @@
 package no.nav.amt_informasjon_api.kafka
 
-import org.apache.kafka.clients.consumer.Consumer
-import org.apache.kafka.clients.consumer.KafkaConsumer
-import org.apache.kafka.common.serialization.StringDeserializer
 import org.apache.kafka.streams.KafkaStreams
 import org.apache.kafka.streams.StreamsBuilder
 import org.apache.kafka.streams.Topology
 import org.jetbrains.exposed.dao.id.IntIdTable
 import org.jetbrains.exposed.sql.selectAll
-import java.time.Duration
 
 class KafkaFactory {
 

diff --git a/backend/src/test/kotlin/no/nav/amt_informasjon_api/ApplicationTest.kt b/backend/src/test/kotlin/no/nav/amt_informasjon_api/ApplicationTest.kt
@@ -1,8 +1,9 @@
 package no.nav.amt_informasjon_api
 
-import io.ktor.application.*
-import io.ktor.http.*
-import io.ktor.server.testing.*
+import io.ktor.application.Application
+import io.ktor.http.HttpMethod
+import io.ktor.server.testing.handleRequest
+import io.ktor.server.testing.withTestApplication
 import org.junit.Test
 import kotlin.test.assertEquals