make schema reg url private

navikt · Apr 25, 2022 · 3ea269d · 3ea269d
1 parent 04fa1a1
commit 3ea269d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/kafka-test/main/no/nav/aap/kafka/streams/test/KafkaStreamsMock.kt b/kafka-test/main/no/nav/aap/kafka/streams/test/KafkaStreamsMock.kt
@@ -16,7 +16,7 @@ import java.util.*
 
 class KafkaStreamsMock : KStreams {
     lateinit var streams: TopologyTestDriver
-    var schemaRegistryUrl: String? = null
+    private var schemaRegistryUrl: String? = null
 
     override fun start(config: KafkaConfig, registry: MeterRegistry, builder: StreamsBuilder.() -> Unit) {
         val topology = StreamsBuilder().apply(builder).build()

diff --git a/kafka-test/test/no/nav/aap/kafka/streams/test/KStreamsMockTest.kt b/kafka-test/test/no/nav/aap/kafka/streams/test/KStreamsMockTest.kt
@@ -7,6 +7,12 @@ import java.util.*
 import kotlin.test.assertNotNull
 import kotlin.test.assertNull
 
+private inline fun KafkaStreamsMock.schemaRegistryUrl(): String? =
+    javaClass.getDeclaredField("schemaRegistryUrl").let {
+        it.isAccessible = true
+        return@let it.get(this) as? String;
+    }
+
 class KStreamsMockTest {
 
     @Test
@@ -27,7 +33,7 @@ class KStreamsMockTest {
 
         kafka.start(config, registry) {}
 
-        assertNull(kafka.schemaRegistryUrl)
+        assertNull(kafka.schemaRegistryUrl())
     }
 
     @Test
@@ -49,6 +55,6 @@ class KStreamsMockTest {
 
         kafka.start(config, registry) {}
 
-        assertNotNull(UUID.fromString(kafka.schemaRegistryUrl?.removePrefix("$schemaUrl/")))
+        assertNotNull(UUID.fromString(kafka.schemaRegistryUrl()?.removePrefix("$schemaUrl/")))
     }
 }