From 6ca12be6f7eeae41266c25b116b5cbcd6dadde35 Mon Sep 17 00:00:00 2001
From: huangjiajun <582604932@qq.com>
Date: Wed, 17 Apr 2024 17:34:13 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=80=E4=B8=AA=E6=A9=98=E5=AD=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 consume/canal_user_relate_consume.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consume/canal_user_relate_consume.go b/consume/canal_user_relate_consume.go
index 5d2d69f..0e6e8f5 100644
--- a/consume/canal_user_relate_consume.go
+++ b/consume/canal_user_relate_consume.go
@@ -62,7 +62,7 @@ func handleCancalUserRelateConsume(msg []byte) error {
 	if masterId != "15763466" {
 		return nil
 	}
-	engine := db.DBs["123456"]
+	engine := db.DBs[masterId]
 	//
 
 	if canalMsg.Type == md.CanalMsgInsertSqlType {