Browse Source

fix renamed variable after merging latest master

Diego Alvarez 5 years ago
parent
commit
899e856c5e
1 changed files with 1 additions and 1 deletions
  1. 1 1
      functional_producer_test.go

+ 1 - 1
functional_producer_test.go

@@ -194,7 +194,7 @@ func TestInterceptors(t *testing.T) {
 	config.Producer.Interceptors = []ProducerInterceptor{&appendInterceptor{i: 0}, &appendInterceptor{i: 100}}
 	config.Consumer.Interceptors = []ConsumerInterceptor{&appendInterceptor{i: 20}}
 
-	client, err := NewClient(kafkaBrokers, config)
+	client, err := NewClient(FunctionalTestEnv.KafkaBrokerAddrs, config)
 	if err != nil {
 		t.Fatal(err)
 	}