fix:binlog监听

services/binlog/handler.go

@@ -77,7 +77,7 @@ func (h *EdbEventHandler) Insert(e *canal.RowsEvent) error {
 				return err
 			}
 		} else {
-			ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo)
+			ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo.EdbInfoId)
 			if err != nil {
 				return err
 			}
@@ -114,7 +114,7 @@ func (h *EdbEventHandler) Update(e *canal.RowsEvent) error {
 				return err
 			}
 		} else {
-			ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo)
+			ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo.EdbInfoId)
 			if err != nil {
 				return err
 			}