|
@@ -154,6 +154,8 @@ func ListenMysql() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+ global.FILE_LOG.Debug("记录上一次启动时的fileName:", fileName, ";position:", position)
|
|
|
+
|
|
|
binlogHandler := &MyEventHandler{}
|
|
|
binlogHandler.SetBinlogFileName(fileName, position)
|
|
|
c.SetEventHandler(binlogHandler)
|