Skip to content

Commit 4532bbd

Browse files
committed
fix build on TeamCity for consumer test
1 parent 1b398eb commit 4532bbd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

consumer/src/test/kotlin/integrations/kafka/KafkaEventSinkNoTopicAutocreationIT.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ class KafkaEventSinkNoTopicAutoCreationIT {
6767
fun `should consume only the registered topic`() {
6868
// given
6969
val topic = "shouldWriteCypherQuery"
70-
val client = AdminClient.create(mapOf("bootstrap.servers" to "localhost:" + kafka.firstMappedPort))
70+
val client = AdminClient.create(mapOf("bootstrap.servers" to kafka.bootstrapServers.substring("PLAINTEXT://".length)))
7171
val expectedTopics = listOf(topic)
7272
client.createTopics(expectedTopics.map { NewTopic(it, 1, 1) })
7373
.all()

0 commit comments

Comments
 (0)