Fix hardcoded kafka version

IBM · Sep 11, 2020 · f76a57e · f76a57e
1 parent 1410fd6
commit f76a57e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/functional_test.go b/functional_test.go
@@ -121,8 +121,8 @@ func prepareDockerTestEnvironment(ctx context.Context, env *testEnvironment) err
 	switch env.KafkaVersion {
 	case "2.6.0":
 		confluentPlatformVersion = "5.5.0"
-	case "2.4.1":
-		confluentPlatformVersion = "5.4.2"
+	case "2.5.1":
+		confluentPlatformVersion = "5.5.0"
 	default:
 		return fmt.Errorf("don't know what confluent platform version to use for kafka %s", env.KafkaVersion)
 	}