fix: fix the get zkAddress error

2 years ago · a83d641a73
parent 0b9d677beb
commit a83d641a73
1 changed files with 1 additions and 1 deletions
--- a/tools/component/component.go
+++ b/tools/component/component.go
@ -205,7 +205,7 @@ func checkRedis() (string, error) {
 func checkZookeeper() (string, error) {
 	// Prioritize environment variables

-	address := getEnv("ZOOKEEPER_USERNAME", config.Config.Zookeeper.Username)
+	address := getEnv("ZOOKEEPER_ADDRESS", strings.Join(config.Config.Zookeeper.ZkAddr, ","))

 	zk := &component.Zookeeper{
 		Schema:   getEnv("ZOOKEEPER_SCHEMA", "digest"),