updated local code

This commit is contained in:
Shlomi Noach 2017-10-02 08:42:38 +03:00
parent 5a9745e2b6
commit 3dd15dfd18

View File

@ -49,7 +49,7 @@ func NewGoMySQLReader(connectionConfig *mysql.ConnectionConfig) (binlogReader *G
User: connectionConfig.User,
Password: connectionConfig.Password,
}
binlogReader.binlogSyncer = replication.NewBinlogSyncer(binlogSyncerConfig)
binlogReader.binlogSyncer = replication.NewBinlogSyncer(*binlogSyncerConfig)
return binlogReader, err
}