|
|
@@ -91,7 +91,7 @@ func ListenMysql() {
|
|
|
// 主从复制的身份id配置，必须全局唯一，如果没有配置的话，那么会随机生成一个
|
|
|
serverId := global.CONFIG.Mysql.Binlog.ServerID
|
|
|
if serverId == 0 {
|
|
|
- serverId = uint32(rand.New(rand.NewSource(time.Now().Unix())).Intn(1000)) + 1001
|
|
|
+ serverId = uint32(rand.New(rand.NewSource(time.Now().UnixNano())).Intn(1000)) + 1001
|
|
|
}
|
|
|
cfg := &canal.Config{
|
|
|
// 一个32位无符号整数，用于标识当前 Canal 实例在 MySQL 主从复制体系中的身份。这里使用了一个随机数生成器确保每次启动时分配的 ServerID 是唯一的（在1001到1099之间）。在实际生产环境中，你需要手动指定一个全局唯一的 ServerID。
|
