From 1b398eb700d0614e149d879feecfba7e51f4ae3a Mon Sep 17 00:00:00 2001 From: Andrea Santurbano Date: Thu, 23 Jan 2020 14:21:51 +0100 Subject: [PATCH 1/2] fix build on TeamCity (#275) --- .../integrations/KafkaEventRouterNoTopicAutocreationIT.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/producer/src/test/kotlin/streams/integrations/KafkaEventRouterNoTopicAutocreationIT.kt b/producer/src/test/kotlin/streams/integrations/KafkaEventRouterNoTopicAutocreationIT.kt index 7a54a648..58873486 100644 --- a/producer/src/test/kotlin/streams/integrations/KafkaEventRouterNoTopicAutocreationIT.kt +++ b/producer/src/test/kotlin/streams/integrations/KafkaEventRouterNoTopicAutocreationIT.kt @@ -52,7 +52,7 @@ class KafkaEventRouterNoTopicAutocreationIT { Assume.assumeTrue("Kafka container has to exist", exists) Assume.assumeTrue("Kafka must be running", kafka.isRunning) - val client = AdminClient.create(mapOf("bootstrap.servers" to "localhost:" + kafka.firstMappedPort)) + val client = AdminClient.create(mapOf("bootstrap.servers" to kafka.bootstrapServers.substring("PLAINTEXT://".length))) val topicsToCreate = listOf("person") client.createTopics(topicsToCreate.map { NewTopic(it, 1, 1) }) .all() From 4532bbd8dace69cebc189d03dac2bb4f69519fc8 Mon Sep 17 00:00:00 2001 From: Andrea Santurbano Date: Thu, 23 Jan 2020 14:54:25 +0100 Subject: [PATCH 2/2] fix build on TeamCity for consumer test --- .../integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer/src/test/kotlin/integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt b/consumer/src/test/kotlin/integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt index b40e20d7..cccfa656 100644 --- a/consumer/src/test/kotlin/integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt +++ b/consumer/src/test/kotlin/integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt @@ -67,7 +67,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.substring("PLAINTEXT://".length))) val expectedTopics = listOf(topic) client.createTopics(expectedTopics.map { NewTopic(it, 1, 1) }) .all()