kgo tests: initialize admin client after env var parsing

twmb · Dec 31, 2023 · 1d92357 · 1d92357
1 parent 556e271
commit 1d92357
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/pkg/kgo/helpers_test.go b/pkg/kgo/helpers_test.go
@@ -55,11 +55,6 @@ var (
 
 func init() {
 	var err error
-	adm, err = newTestClient()
-	if err != nil {
-		panic(fmt.Sprintf("unable to create admin client: %v", err))
-	}
-
 	if n, _ := strconv.Atoi(os.Getenv("KGO_TEST_RF")); n > 0 {
 		testrf = n
 	}
@@ -137,6 +132,10 @@ func init() {
 			}
 		}
 	}
+	adm, err = newTestClient()
+	if err != nil {
+		panic(fmt.Sprintf("unable to create admin client: %v", err))
+	}
 }
 
 func testClientOpts(opts ...Opt) []Opt {