连接中再次创建临时节点时将zk版本设置为0 (#92)

Co-authored-by: kalvinzhang <kalvinzhang@futunn.com>

Author: kalvinzhang

client/cluster_canal_connector.go

@@ -3,12 +3,13 @@ package client
 import (
 	"errors"
 	"fmt"
-	"github.com/go-zookeeper/zk"
 	"log"
 	"sort"
 	"strings"
 	"time"
 
+	"github.com/go-zookeeper/zk"
+
 	pb "github.com/withlin/canal-go/protocol"
 )
 
@@ -284,6 +285,8 @@ func (cc *ClusterCanalConnector) waitBecomeFirst() error {
 			if err != nil {
 				return err
 			}
+			// 再次创建临时节点成功后将版本设置为0，不然后续更新节点会出现版本冲突
+			cc.zkVersion = 0
 			return cc.waitBecomeFirst()
 		}
 	}