fix CI build

neo4j-contrib · Apr 2, 2020 · 0df75fa · 0df75fa
1 parent 2ca72aa
commit 0df75fa
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/consumer/src/test/kotlin/integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt b/consumer/src/test/kotlin/integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt
@@ -68,7 +68,7 @@ class KafkaEventSinkNoTopicAutoCreationIT {
     fun `should consume only the registered topic`() {
         // given
         val topic = "shouldWriteCypherQuery"
-        val client = AdminClient.create(mapOf("bootstrap.servers" to "localhost:" + kafka.firstMappedPort))
+        val client = AdminClient.create(mapOf("bootstrap.servers" to kafka.bootstrapServers))
         val expectedTopics = listOf(topic)
         client.createTopics(expectedTopics.map { NewTopic(it, 1, 1) })
                 .all()

diff --git a/producer/src/test/kotlin/streams/integrations/KafkaEventRouterNoTopicAutocreationIT.kt b/producer/src/test/kotlin/streams/integrations/KafkaEventRouterNoTopicAutocreationIT.kt
@@ -51,7 +51,7 @@ class KafkaEventRouterNoTopicAutocreationIT {
             Assume.assumeTrue("Kafka container has to exist", exists)
             Assume.assumeTrue("Kafka must be running", ::kafka.isInitialized && kafka.isRunning)
 
-            val client = AdminClient.create(mapOf("bootstrap.servers" to "localhost:" + kafka.firstMappedPort))
+            val client = AdminClient.create(mapOf("bootstrap.servers" to kafka.bootstrapServers))
             val topicsToCreate = listOf("person")
             client.createTopics(topicsToCreate.map { NewTopic(it, 1, 1) })
                     .all()