diff --git a/common/store/zookeeper/db.go b/common/store/zookeeper/db.go index bbd41fa..da06eca 100644 --- a/common/store/zookeeper/db.go +++ b/common/store/zookeeper/db.go @@ -30,7 +30,10 @@ func New() *zkDB { func (db *zkDB) Login() error { var err error - db.Con, _, err = zk.Connect([]string{db.Cfg}, time.Second*60) + // to support zk cluster + servers := strings.Split(db.Cfg, ",") + db.Con, _, err = zk.Connect(servers, time.Second*60) + //db.Con, _, err = zk.Connect([]string{db.Cfg}, time.Second*60) if err != nil { panic(err) }