fix CI build

Author: conker84

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()

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()