From 43af7c87f453b9875ec11a2a631dc5c5109a1465 Mon Sep 17 00:00:00 2001 From: Konstantinos Tsanaktsidis Date: Wed, 24 Jun 2020 13:51:24 +1000 Subject: [PATCH] Remove redundant hard-coding of env.KafkaVersion --- functional_test.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/functional_test.go b/functional_test.go index 2391725a41..b61a43dafb 100644 --- a/functional_test.go +++ b/functional_test.go @@ -153,11 +153,6 @@ func prepareDockerTestEnvironment(ctx context.Context, env *testEnvironment) err env.KafkaBrokerAddrs = append(env.KafkaBrokerAddrs, fmt.Sprintf("127.0.0.1:%d", 29090+i)) } - // the mapping of confluent platform docker image vesions -> kafka versions can be - // found here: https://docs.confluent.io/current/installation/versions-interoperability.html - // We have cp-5.5.0 in the docker-compose file, so that's kafka 2.5.0. - env.KafkaVersion = "2.5.0" - // Wait for the kafka broker to come up allBrokersUp := false for i := 0; i < 45 && !allBrokersUp; i++ {