Kafka connectString generation with brokerHost variable

andreas-schroeder · Aug 10, 2017 · 3dde610 · 3dde610
1 parent f4caac3
commit 3dde610
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/check/setup.go b/check/setup.go
@@ -31,7 +31,7 @@ func (check *HealthCheck) connect(firstConnection bool, stop <-chan struct{}) er
 func (check *HealthCheck) tryConnectOnce(createBrokerTopic, createReplicationTopic *bool) error {
 	pauseTime := check.config.retryInterval
 	// connect to kafka cluster
-	connectString := []string{fmt.Sprintf("localhost:%d", check.config.brokerPort)}
+	connectString := []string{fmt.Sprintf("%s:%d", check.config.brokerHost, check.config.brokerPort)}
 	err := check.broker.Dial(connectString, check.brokerConfig())
 	if err != nil {
 		log.Printf("unable to connect to broker, retrying in %s (%s)", pauseTime.String(), err)