Update functional_test.go

agriffaut · Nov 23, 2021 · f345558 · f345558
1 parent f1fd3bc
commit f345558
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/functional_test.go b/functional_test.go
@@ -112,8 +112,8 @@ func prepareDockerTestEnvironment(ctx context.Context, env *testEnvironment) err
 	if version, ok := os.LookupEnv("KAFKA_VERSION"); ok {
 		env.KafkaVersion = version
 	} else {
-		// We have cp-6.1.2 as the default in the docker-compose file, so that's kafka 2.7.1.
-		env.KafkaVersion = "2.7.1"
+		// We have cp-7.0.0 as the default in the docker-compose file, so that's kafka 3.0.0.
+		env.KafkaVersion = "3.0.0"
 	}
 
 	// the mapping of confluent platform docker image versions -> kafka versions can be