Skip to content

Commit 1b398eb

Browse files
authored
fix build on TeamCity (#275)
1 parent 357eb1a commit 1b398eb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

producer/src/test/kotlin/streams/integrations/KafkaEventRouterNoTopicAutocreationIT.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ class KafkaEventRouterNoTopicAutocreationIT {
5252
Assume.assumeTrue("Kafka container has to exist", exists)
5353
Assume.assumeTrue("Kafka must be running", kafka.isRunning)
5454

55-
val client = AdminClient.create(mapOf("bootstrap.servers" to "localhost:" + kafka.firstMappedPort))
55+
val client = AdminClient.create(mapOf("bootstrap.servers" to kafka.bootstrapServers.substring("PLAINTEXT://".length)))
5656
val topicsToCreate = listOf("person")
5757
client.createTopics(topicsToCreate.map { NewTopic(it, 1, 1) })
5858
.all()

0 commit comments

Comments
 (0)